我有一个spring引导应用程序,我正在使用kafka主题的消息,并将消息存储在DB中。我有一个处理DB fail的要求,如果DB关闭,则不应该提交该消息,并在一段时间后暂停消费消息,然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which is internally usi
我使用和Spring,所以我创建了自定义监听器来读取来自主题的消息,并将它们放到spring集成通道上。经过一定的间隔,比如10-12个小时后,吊舱重新启动和应用程序启动成功,没有错误,但在某个时间之后。org.apache.kafka.common.errors.TopicAuthorizationException: Not aut