Support Questions

Find answers, ask questions, and share your expertise

unable to send message from kafka producer in kafka 2.1.1

Contributor

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

2 REPLIES 2

Explorer

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

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

New Contributor

This happens with me also. Amazingly, it gives the exact same timeout ms.

 

[Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.