Is your network saturated? If yes, you can try to start more instances
of Kafka Streams instead of running with multiple thread within one
instance to increase available network capacity.


On 2/8/18 12:30 AM, ? ? wrote:
> Hi:
> I used kafka streaming for real time analysis.
> and I put stream_thread_num same with partitions of topic
> and set ConsumerConfig.max_poll_records =500
> I use foreach  method only in this
> but find with large records in kafka. the cosumer LAG is big some times and 
> trigger kafka topic rebalance.
> How to how to enhance Kafka streaming Consumer rate ?
> ________________________________

Attachment: signature.asc
Description: OpenPGP digital signature

Reply via email to