gpssfmt = UDF(kafka_in)
client(psql) ---> Master: SELECT * FROM kafka_in('...');
/|\ |
| grpc |
| Add |
| Start |
| Offset |
| \|/
\|/ grpc / Segment (kafka_in)
worker <--------- Segment (kafka_in)
Consume \ Segment (kafka_in)
- client->worker, add kafka job
- client->worker, start kafka job
- client->master, SELECT * FROM kafka_in('');
- segment->worker, consume kafka data