通过这个网站,我创建了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);
}
有人能帮忙吗??
暂无答案!
目前还没有任何答案,快来回答吧!