Great to hear and thanks for letting us know. Cheers, Till
On Wed, Dec 19, 2018 at 5:39 PM Gerard Garcia <ger...@talaia.io> wrote: > We finally figure it out. We had a large value in the Kafka consumer > option 'max.partition.fetch.bytes', this made the KafkaConsumer to not > consume at a balanced rate from all partitions. > > Gerard >