This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 33853c1  MINOR: Correct usage of ConfigException in file and directory 
config providers
     add c219fba  KAFKA-13419: Only reset generation ID when ILLEGAL_GENERATION 
error (#11451)

No new revisions were added by this update.

Summary of changes:
 .../consumer/internals/AbstractCoordinator.java    | 54 ++++++++-----
 .../consumer/internals/ConsumerCoordinator.java    | 18 +++--
 .../internals/ConsumerCoordinatorTest.java         | 92 ++++++++++++++++++++--
 .../main/scala/kafka/server/DelayedOperation.scala |  4 +-
 4 files changed, 132 insertions(+), 36 deletions(-)

Reply via email to