I have added this to my consumer config, and now it works fine.
receive.buffer.bytes=1048576
On Wed, Nov 13, 2019 at 10:41 AM Upendra Yadav
wrote:
> Hi,
>
> I m using consumer assign method and consume with 15000 poll time out to
> consume single partition data from another DC.
>
> Below are m
Hi,
I m using consumer assign method and consume with 15000 poll time out to
consume single partition data from another DC.
Below are my consumer configs:
enable.auto.commit=false
max.poll.records=4000
max.partition.fetch.bytes=4096000
key.deserializer=org.apache.kafka.common.serialization.ByteAr
