guozhangwang commented on pull request #9084:
URL: https://github.com/apache/kafka/pull/9084#issuecomment-664698317

   @abbccdda The exception is thrown from the consumer.poll, and the caller of 
the consumer could be expecting specific exceptions, e.g. TaskMigratedException 
will be handled specifically in Streams, but a general KafkaException would be 
treated as a fatal error.
   
   We're already doing this e.g. in ConsumerCoordinator line 432, but it is not 
done in all occasions, so I'm just trying to make the behavior to be consistent 
across all callers here.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to