question Re: Error publishing a message after upgrading kafka parcel in Archives of Support Questions (Read Only)

Error publishing a message after upgrading kafka parcel

Bhairav — Fri, 16 Sep 2022 10:04:44 GMT

Aftre upgrading kafka parcel from "0.8.2.0-1.kafka1.4.0.p0.56" to "2.0.0-1.kafka2.0.0.p0.12".

Running into an issue were by publishing message on to topic fails.

A simple test using kafka-console-producer fails withe error message

Error when sending message to topic TESTTOPIC with key: null, value: 9 bytes with error: Failed to update metadata after 60000 ms. (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)

Please advise.

Re: Error publishing a message after upgrading kafka parcel

Bhairav — Fri, 19 Feb 2016 02:35:07 GMT

Figured out that I had to change a setting in server.properties

listeners=PLAINTEXT://hostname:9092

listeners=PLAINTEXT://0.0.0.0:9092

and everything seemed to work fine now.

Re: Error publishing a message after upgrading kafka parcel

obesechicken13 — Wed, 11 May 2016 21:41:41 GMT

Hi Bhairav,

I've recently started using Cloudera Enterprise. I was wondering how you were able to solve the kafka issue. I'm still having trouble solving this issue because I don't know where the server.properties file is located.

Or where I can find the "listeners" property in cloudera manager. I tried checking kafka's configuration tab but didn't find this setting.

https://community.cloudera.com/t5/Cloudera-Manager-Installation/Error-publishing-a-message-after-upgrading-kafka-parcel/td-p/37640

Re: Error publishing a message after upgrading kafka parcel

MSharma — Fri, 29 Jul 2016 19:05:54 GMT

in cloudera manager it is kafka.properties .

you can update values in borker configuration ==> advanced ==> Kafka broker Advanced Configuration Snippet (Safety Valve) for kafka.properties

and restart

Re: Error publishing a message after upgrading kafka parcel

clouderakruzer — Tue, 23 Jan 2018 19:55:38 GMT

If you have kafka version - 0.10.2, then adding only the 'listeners' is not enough and 'advertised.listeners' should also be added to the safety valve values for 'kafka.properties'. This is more of a requirement when we set the ip address as '0.0.0.0'. The advertised.listeners value would have the exact ip/hostname:port value.

This information is clearly mentioned at - http://kafka.apache.org/documentation.html#security_configbroker