Spring (2.0.1.RELEASE)发送消息。$ListenerConsumer.run(KafkaMessageListenerContainer.java:699) ~[spring-kafka-2.1.5.RELEASE.jar:2.1.5.=xx.xx.xx.xx:50070spring.kafka.properties.security.protocol=SSL
sprin
我有一个kafka监听器,它正确地接收数据,但EventData ss = consumerRecord.value()提供ClassCastException。我使用的是默认的spring启动设置。我不确定它是如何正确接收消息的,当我尝试使用它时,它给出了异常。org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:112) ~[spring-messaging(HandlerAda