sarama.PacketDecodingError=kafka : error decoding packet: message of length 1213486160 too large or too small

[programmer4m]

Kafka Version:2.12
Go Version: 1.10.3

Problem Description

I find this in the log , no other issues found .
WARN kafka message: client/metadata got error from broker while fetching metadata:%!(EXTRA sarama.PacketDecodingError=kafka: error decoding packet: message of length 1213486160 too large or too small)

In detail log :

WARN kafka message: Initializing new client
WARN client/metadata fetching metadata for all topics from broker
WARN Connected to broker at ...... (unregistered)
WARN kafka message: client/metadata got error from broker while fetching metadata:%!(EXTRA sarama.PacketDecodingError=kafka: error decoding packet: message of length 1213486160 too large or too small)
WARN Closed connection to broker
WARN kafka message: client/metadata no available broker to send metadata request to
WARN client/brokers resurrecting 1 dead seed brokers

[wladh]

Might be a dup of #1144
There's no Kafka: 2.12, do you mean Kafka 2.0 compiled with Scala 2.12?

[d1egoaz]

#1199 seems a dup of this

would this workaround work for you @programmer4m ?#1199 (comment)

[ghost]

Thank you for taking the time to raise this issue. However, it has not had any activity on it in the past 90 days and will be closed in 30 days if no updates occur.
Please check if the master branch has already resolved the issue since it was raised. If you believe the issue is still valid and you would like input from the maintainers then please comment to ask for it to be reviewed.

[lovasoa]

• 1213486160 is the decimal representation of 0x48 0x54 0x54 0x50 which is HTTP in ascii
• What happened is probably this: A client expecting a binary payload (such as kafka) received an HTTP response instead. It may either be talking to the wrong host and port, or there is an HTTP proxy (such as kubernetes ingress) where there shouldn't be one.