Problem was on the consumer which was using default max.poll.records = 500
max.poll.records = 500
After increasing it, everything work as expected