search

pipelinedb / pipeline_kafka

PipelineDB extension for Kafka support
Other
61 stars 22 forks source link

New features: support pipeline_kafka.consume_status() #71

Open EamonZhang opened 7 years ago

EamonZhang commented 7 years ago

function pipeline_kafka.consume_begin() pipeline_kafka.consume_end()

make consumer status change between start and stop , known what's the status current is also needed.