Консоль Kafka Consumer не получает никакого значения от производителя? - PullRequest
Новая
       2

Консоль Kafka Consumer не получает никакого значения от производителя?

0 голосов
/ 09 мая 2019

Проходя по этому сайту, я создал Kafka Producer и Kafka Consumer

https://www.tutorialkart.com/apache-kafka/kafka-console-producer-and-consumer-example/

, но мой потребитель не принимает никакой ценности от моего производителя, поэтому я решил принять через Spring-bootно в том же случае потребитель не принимает значение производителя.

Я просмотрел несколько постов в StackOverFlow, но ни один из них не решил мою проблему.

Вот мой код в Spring.

Application.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);
}

Может кто-нибудь помочь ??

...