unable to send message from kafka producer in kafka 2.1.1

[#1]

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]

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

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

[#3]

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.