控制台Kafka消费者没有收到任何价值从生产者?

eiee3dmh  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(173)

通过这个网站,我创建了Kafka生产者和Kafka消费者
https://www.tutorialkart.com/apache-kafka/kafka-console-producer-and-consumer-example/
但是我的消费者没有从我的制作者那里得到任何价值,所以我决定通过spring boot接受,但同样的情况下,消费者没有从制作者那里得到任何价值。
我在stackoverflow中浏览了几个帖子,但没有一个能解决我的问题。
这是我Spring的代码。
应用程序.java

@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
        ConcurrentKafkaListenerContainerFactoryConfigurer configurer,
        ConsumerFactory<Object, Object> kafkaConsumerFactory,
        KafkaTemplate<Object, Object> template) {
    ConcurrentKafkaListenerContainerFactory<Object, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
    configurer.configure(factory, kafkaConsumerFactory);
    factory.setErrorHandler(new SeekToCurrentErrorHandler(
            new DeadLetterPublishingRecoverer(template), 3)); // dead-letter after 3 tries
    return factory;
}

和consumer.java

@KafkaListener(id = "com.stellapps.rtcreset.kafka.consumer", topics = "${rawEventsTopicName}") // add it in   config part
public void messageListener(String in) {
    System.out.println("Received from message: " + in);
    rtcInterpreter.call(in,url);
}

有人能帮忙吗??

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题