poll block question

2021-11-24 Thread xusheng
hi i find something not sure about poll. i need some help my kafka server version is 1.1.0 my kafka client version is 2.3.0 then 128 partition of topic xxx, start 128 thread in one application to consume message. always run well, but run about a week long , i find there is a consumer hang forever

Re: poll block question

2021-11-24 Thread Luke Chen
Hi xusheng, I checked the code stack, and mapped to the kafka code, I can see we either use Selector#selectNow, or Selector#select(timeoutMs), which should never hang forever. If so, I think it might be the `timeoutMS` is too large, and from your code stack, the timeoutMS came from the Consumer#pol