控制kafka消费者监听器 [英] Controlling kafka consumer listener
本文介绍了控制kafka消费者监听器的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
Assume Kafka consumer has to consume 5 data and it has to process in A class & B class.
5 Data --> KAFKA CONSUMER --> PROCESS A CLASS ---> PROCESS B Class.
Whether 5 data will be consumed immediately one by one or is there any time period to consume one data after next data. Reason for this question is if Data1 data is consumed in the above flow and PROCESS B class take longer timer whether DATA 2 will consume before PROCESS B class completes.
我尝试过的事情：
What I have tried:
Whether 5 data will be consumed immediately one by one or is there any time period to consume one data after next data. Reason for this question is if Data1 data is consumed in the above flow and PROCESS B class take longer timer whether DATA 2 will consume before PROCESS B class completes.
推荐答案
介绍Kafka消费者：新的Apache Kafka 0.9消费者客户端入门 - 汇合 [ ^ ]
这篇关于控制kafka消费者监听器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
