Results
2
issues of
Eamon
How to configure the nodes when they have different ssh port ？
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.