Reply
Expert Contributor
Posts: 125
Registered: ‎08-07-2017

unable to send message from kafka producer in kafka 2.1.1

[ Edited ]

Hello All,

 

I am also facing the issue of sending messages from producer. Our cluster is not having kerberos.Getting below error.

 

18/09/11 02:28:20 ERROR internals.ErrorLoggingCallback: Error when sending message to topic Topic_Landing_dev with key: null, value: 2 bytes with error:
org.apache.kafka.common.errors.TimeoutException: Expiring 2 record(s) for Topic_0 due to 1599 ms has passed since batch creation plus linger time
18/09/11 02:28:20 ERROR internals.ErrorLoggingCallback: Error when sending message to topic Topic_Landing_dev with key: null, value: 5 bytes with error:
org.apache.kafka.common.errors.TimeoutException: Expiring 2 record(s) for Topic_0 due to 1599 ms has passed since batch creation plus linger time
^C18/09/11 02:30:58 INFO producer.KafkaProducer: Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

 

In kafka logs at location /var/log/kafka , I see message like below

 ERROR kafka.server.ReplicaFetcherThread: [ReplicaFetcherThread-0-243], Error for partition [__consumer_offsets,19] to broker 243:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

 

kafka broker with id 243 is not available. Please help.

 

Thanks,

Priya

Explorer
Posts: 12
Registered: ‎05-21-2018

Re: unable to send message from kafka producer in kafka 2.1.1

Are you able to send messages from the command line tool like so:

$ kafka-console-producer --broker-list <yourhost>:9092 --topic test-topic

Announcements
New solutions