我有一个kafka监听器,它正确地接收数据,但EventData ss = consumerRecord.value()提供ClassCastException。我使用的是默认的spring启动设置。我不确定它是如何正确接收消息的,当我尝试使用它时,它给出了异常。org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:112) ~[spring-messaging(H
我有一个springbootkafka消费者和一个springbootkafka生产者,当我在终端中启动消费者并在启动生产者之后,消费者收到数据时,如果且仅当我按下任何键盘键时,我不知道为什么= new HashMap<>();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress)