sven-lange-last edited a comment on issue #3912: Fix max.poll.interval.ms 
setting of KafkaConsumer.
URL: 
https://github.com/apache/incubator-openwhisk/pull/3912#issuecomment-408808728
 
 
   The Kafka new Java consumer documentation contains the following hint in the 
[notables changes section for 
0.10.1.0](https://kafka.apache.org/documentation/#upgrade_1010_notable):
   
   > The new Java Consumer now supports heartbeating from a background thread. 
There is a new configuration max.poll.interval.ms which controls the maximum 
time between poll invocations before the consumer will proactively leave the 
group (5 minutes by default). **The value of the configuration 
request.timeout.ms must always be larger than max.poll.interval.ms because this 
is the maximum time that a JoinGroup request can block on the server while the 
consumer is rebalancing**, so we have changed its default value to just above 5 
minutes.
   
   At the moment, we have `request.timeout.ms` < `max.poll.interval.ms` and 
this PR will also keep the value smaller.
   
   I guess that this should not harm in our situation with a single consumer 
group per topic, a single partition per topic and a single consumer process in 
the consumer group. But I don't understand all implications...

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to