kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (39278d3 -> 6da70f9)
Date Tue, 14 Jan 2020 03:21:32 GMT
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%)


Mime
View raw message