[GitHub] [camel-k] chander35 opened a new issue, #4186: Unable to produce and consume in camel-k to apache kafka, getting error like "Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available."

[via GitHub]

chander35 opened a new issue, #4186:
URL: https://github.com/apache/camel-k/issues/4186

   I have created a sample camel-k program to produce and another program to 
consume as mentioned below, after the execution of "kamel run 
KafkaProducer.java --dev" for producing the message, 
   
   ex:- KafkaProducer.java
   <img width="343" alt="image" 
src="https://user-images.githubusercontent.com/128601152/228489074-fcf6b74c-3dac-40d6-b13a-a330e563aaf6.png";>
   
   "kamel run KafkaConsumer.java --dev" for consuming the message, ****
   
   ex:- KafkaConsumer.java
   <img width="352" alt="image" 
src="https://user-images.githubusercontent.com/128601152/228489821-391f10da-dd0e-4ec1-b6db-89c3f0241342.png";>
   
   but every time iam getting error like this:
   
   " ******* Consumer clientId=consumer-0c981e6e-3fbb-4bbf-9142-9c4f6d6e3254-1, 
groupId=0c981e6e-3fbb-4bbf-9142-9c4f6d6e3254] Bootstrap broker localhost:9092 
(id: -1 rack: null) disconnected←[39m←[38;5;203m←[39m←[38;5;227m" @producer
   and 
   "Connection to node -1 (localhost/127.0.0.1:9092) could not be established. 
Broker may not be available."@consumer
   
   even though i have added below mentioed commands in application.properties, 
iam not able to consume messages.
   
   camel.component.kafka.brokers=localhost:9092
   listeners=PLAINTEXT://localhost:9092
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org