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 e94f5dc  KAFKA-9294: Add tests for Named parameter (#7874)
     add 505e824  KAFKA-8421: Still return data during rebalance (#7312)

No new revisions were added by this update.

Summary of changes:
 .../clients/consumer/CommitFailedException.java    |   4 +
 .../kafka/clients/consumer/KafkaConsumer.java      | 132 +++++++++++++--------
 .../clients/consumer/OffsetCommitCallback.java     |   4 +
 .../consumer/RetriableCommitFailedException.java   |   6 -
 .../consumer/internals/AbstractCoordinator.java    |  34 +++++-
 .../consumer/internals/ConsumerCoordinator.java    |  66 +++++++----
 .../consumer/internals/KafkaConsumerMetrics.java   |   3 +-
 .../consumer/internals/SubscriptionState.java      |  11 +-
 .../java/org/apache/kafka/clients/MockClient.java  |   2 -
 .../kafka/clients/consumer/KafkaConsumerTest.java  | 114 ++++++++++++++++++
 .../internals/ConsumerCoordinatorTest.java         |  19 ++-
 .../consumer/internals/SubscriptionStateTest.java  |   2 +-
 .../kafka/api/EndToEndAuthorizationTest.scala      |  37 +++---
 .../streams/processor/internals/StreamTask.java    |   6 +
 14 files changed, 331 insertions(+), 109 deletions(-)