这是我第一次使用卡夫卡。我有一个spring引导应用程序,我正在使用kafka主题的消息,并将消息存储在DB中。我有一个处理DB fail的要求,如果DB关闭,则不应该提交该消息,并在一段时间后暂停消费消息,然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which is in
consumer_group是我使用spring-kafka客户端的spring-boot应用程序,而且总是有一个针对该消费者群体的single consumer。spring-kafka version 1.1.8 RELEASE当我使用burrow查询特定的burrow时,我看到15偏移项用于相同的<