Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

unable to send message from kafka producer in kafka 2.1.1

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
Highlighted

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

Explorer

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

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

Highlighted

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

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.

Don't have an account?
Coming from Hortonworks? Activate your account here