You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
While running consumer from kafka input with configured auto.offset.reset = earliest I get error and my consumer can not receive messages anymore:
Receive failed: Invalid response size 4020574 (0..4000000): increase receive.message.max.bytes (after 5ms in state UP, 4 identical error(s) suppressed).
I use fluent bit kafka input with buffer_max_size 4M.
Description
librdkafka v2.4.0
kafka broker 3.4.1
Debian 12 x86_64
consumer config:
receive.message.max.bytes = 4194304 (4M)
fetch.max.bytes=4194304 - 512
auto.offset.reset = earliest
While running consumer from kafka input with configured auto.offset.reset = earliest I get error and my consumer can not receive messages anymore:
Receive failed: Invalid response size 4020574 (0..4000000): increase receive.message.max.bytes (after 5ms in state UP, 4 identical error(s) suppressed).
I use fluent bit kafka input with buffer_max_size 4M.
Source:
https://github.com/fluent/fluent-bit/blob/master/plugins/in_kafka/in_kafka.c
Message and fetch size configuration code:
https://github.com/fluent/fluent-bit/blob/master/plugins/in_kafka/in_kafka.c#L246
How to reproduce
Just make sure the producer generates messages faster than the consumer consumes
Issue is similar to already closed one:
#1616
Checklist
IMPORTANT: We will close issues where the checklist has not been completed.
Please provide the following information:
v2.4.0
3.4.1
receive.message.max.bytes = 4194304 (4M) fetch.max.bytes=4194304 - 512 auto.offset.reset = earliest
Debian 12 x86_64
debug=..
as necessary) from librdkafkaThe text was updated successfully, but these errors were encountered: