我们如何检查主题上没有更多的事件或消息要消费？
有没有办法检查该主题上没有更多的事件或在Spring Boot Kafka中消费的消息。在我的情况下，我有一个要求，例如我从Kafka主题的两个通道源的数据中收到数据，而另一个可以通过连接到其他DB来获得完整的数据转储。因此，在消耗了Kafka主题中的所有消息后，我需要将我从主题中收到的数据计数与我从DB连接中获得的其他数据计数进行比较。
可以这样做吗？我知道如何在Spring Boot中编写代码以开始消费Kafka主题的事件以及如何使数据库连接从一个DB表获取数据并插入另一个DB表
Is there a way we can check there are no more events or messages is left on the topic to consume in Spring Boot Kafka. In my scenario, I have a requirement like I receive data from the two-channel source one from Kafka topic, and another I can get a complete dump of data by connecting to some other DB. So there is a case after consuming all the messages from Kafka Topic I need to compare the count of data that I have received from Topic with the other data count which I get from DB connectivity.
Is it possible to do so? I know how to write the code in spring boot to start consuming events from Kafka topic and how to make a DB connectivity get data from one DB table and insert it another db table
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
请参阅有关检测空闲侦听器的文档容器。
See the documentation about detecting idle listener containers.