Description

I have kafak 0.10.2.0 server, and having setting: message.max.bytes=1500012 (1.5MB), and I have Go client: librdkafka-dev_0.11.0 0n Ubuntu 14.04 (Debian package). Go version 1.9.0 I got two kinds of wired error on Go client side: %3|1506735207.752|FAIL|rdkafka#consumer-6| [thrd:ps6655.prn.parsec.abc.com:9092/2]: ps6655.prn.parsec.abc.com:9092/2: Receive failed: Invalid response size 1000000040 (0…1000000000): increase receive.message.max.bytes

ERROR|rdkafka#consumer-6| Receive failed: Invalid response size -2147483555 (0…1000000000):

Why response size over my 1.5MB server allowed received thresold ? Why response size is negative number??? Thanks, ~Jing

How to reproduce

run consumer_channel_example.go with multiple groutines. Checklist

Please provide the following information:

• confluent-kafka-go and librdkafka version (LibraryVersion()): librdkafka-dev_0.11.0
• Apache Kafka broker version: 0.10.2.0
• Client configuration: ConfigMap{...} “consumers”: { “consumerProfiles”: [ { “bootStrapServers”: “kafka-zkb0001.lab.parsec.abc.com:9092,kafka-zkb0002.lab.parsec.abc.com:9092,kafka-zkb0003.lab.parsec.abc.com:9092”, “enableAutoCommit”: false, “autoOffsetReset”: “earliest”, “topic”: “activity”, “consumerGroupID”: “JetTestConsumergroup”, “go.application.rebalance.enable”: true, “go.events.channel.enable”: true, “go.events.channel.size”: 100000 } ] }
• Operating system: Ubuntu 14.04
• Provide client logs (with "debug": ".." as necessary)
• Provide broker log excerpts
• Critical issue