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 ? ________________________________ funk...@live.com
- how to enhance Kafka streaming Consumer rate ? ? ?
- Re: how to enhance Kafka streaming Consumer rate ? Matthias J. Sax