我有一个kafka监听器,它正确地接收数据,但EventData ss = consumerRecord.value()提供ClassCastException。我使用的是默认的spring启动设置。我不确定它是如何正确接收消息的,当我尝试使用它时,它给出了异常。org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:112) ~[
我有一个spring引导应用程序,我正在使用kafka主题的消息,并将消息存储在DB中。我有一个处理DB fail的要求,如果DB关闭,则不应该提交该消息,并在一段时间后暂停消费消息,然后监听器可以再次开始使用消息。做这件事的更好的方法是什么。i am using spring-kafka:2.2.8.RELEASE which is internally using kafka 2.0.1