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 39278d3 KAFKA-9159: The caller of sendListOffsetRequest need to
handle retriable InvalidMetadata (#7665)
add 6da70f9 KAFKA-9346: Consumer back-off logic when fetching pending
offsets (#7878)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 4 +-
.../consumer/internals/ConsumerCoordinator.java | 27 ++++--
...ion.java => UnstableOffsetCommitException.java} | 12 +--
.../org/apache/kafka/common/protocol/Errors.java | 4 +-
.../kafka/common/requests/OffsetFetchRequest.java | 33 +++++--
.../kafka/common/requests/OffsetFetchResponse.java | 1 +
.../common/message/OffsetFetchRequest.json | 8 +-
.../common/message/OffsetFetchResponse.json | 4 +-
.../internals/ConsumerCoordinatorTest.java | 37 +++++---
.../apache/kafka/common/message/MessageTest.java | 24 +++--
.../common/requests/OffsetFetchRequestTest.java | 15 ++-
.../kafka/common/requests/RequestResponseTest.java | 50 ++++++----
.../kafka/coordinator/group/GroupCoordinator.scala | 4 +-
.../kafka/coordinator/group/GroupMetadata.scala | 11 ++-
.../coordinator/group/GroupMetadataManager.scala | 45 +++++----
core/src/main/scala/kafka/server/KafkaApis.scala | 5 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 4 +-
.../coordinator/group/GroupCoordinatorTest.scala | 104 ++++++++++++++++-----
.../group/GroupMetadataManagerTest.scala | 52 ++++++-----
.../coordinator/group/GroupMetadataTest.scala | 21 +++++
.../scala/unit/kafka/server/RequestQuotaTest.scala | 2 +-
21 files changed, 319 insertions(+), 148 deletions(-)
copy
clients/src/main/java/org/apache/kafka/common/errors/{ControllerMovedException.java
=> UnstableOffsetCommitException.java} (80%)
