kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated (ac385c4 -> e24d0e2)
Date Fri, 13 Sep 2019 23:49:55 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from ac385c4  KAFKA-8474; Use HTML lists for config layout (#6870)
     add e24d0e2  KAFKA-8730; Add API to delete consumer offsets (KIP-496) (#7276)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/clients/admin/Admin.java |  23 ++
 ...java => DeleteConsumerGroupOffsetsOptions.java} |   7 +-
 .../admin/DeleteConsumerGroupOffsetsResult.java    |  84 +++++++
 .../kafka/clients/admin/KafkaAdminClient.java      |  93 ++++++++
 .../consumer/internals/ConsumerProtocol.java       |  17 +-
 ...n.java => GroupSubscribedToTopicException.java} |   4 +-
 .../org/apache/kafka/common/protocol/ApiKeys.java  |   5 +-
 .../org/apache/kafka/common/protocol/Errors.java   |   5 +-
 .../kafka/common/requests/AbstractRequest.java     |   2 +
 .../kafka/common/requests/AbstractResponse.java    |   2 +
 ...nTokenRequest.java => OffsetDeleteRequest.java} |  76 ++++---
 .../common/requests/OffsetDeleteResponse.java      |  95 ++++++++
 ...nmentsRequest.json => OffsetDeleteRequest.json} |  27 ++-
 ...dTxnResponse.json => OffsetDeleteResponse.json} |  27 ++-
 .../kafka/clients/admin/KafkaAdminClientTest.java  | 253 +++++++++++++++++++++
 .../kafka/clients/admin/MockAdminClient.java       |   5 +
 .../kafka/common/requests/RequestResponseTest.java |  51 +++++
 .../kafka/coordinator/group/GroupCoordinator.scala |  87 +++++++
 .../kafka/coordinator/group/GroupMetadata.scala    |  81 ++++++-
 .../coordinator/group/GroupMetadataManager.scala   |  25 ++
 core/src/main/scala/kafka/server/KafkaApis.scala   |  52 +++++
 .../kafka/api/AdminClientIntegrationTest.scala     |  82 ++++++-
 .../kafka/api/AuthorizerIntegrationTest.scala      |  74 +++++-
 .../coordinator/group/GroupCoordinatorTest.scala   | 215 ++++++++++++++++-
 .../group/GroupMetadataManagerTest.scala           | 206 +++++++++++++++++
 .../coordinator/group/GroupMetadataTest.scala      |  55 +++++
 .../scala/unit/kafka/server/RequestQuotaTest.scala |  12 +
 27 files changed, 1585 insertions(+), 80 deletions(-)
 copy clients/src/main/java/org/apache/kafka/clients/admin/{DescribeReplicaLogDirsOptions.java
=> DeleteConsumerGroupOffsetsOptions.java} (82%)
 create mode 100644 clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java
 copy clients/src/main/java/org/apache/kafka/common/errors/{InvalidPidMappingException.java
=> GroupSubscribedToTopicException.java} (87%)
 copy clients/src/main/java/org/apache/kafka/common/requests/{CreateDelegationTokenRequest.java
=> OffsetDeleteRequest.java} (52%)
 create mode 100644 clients/src/main/java/org/apache/kafka/common/requests/OffsetDeleteResponse.java
 copy clients/src/main/resources/common/message/{ListPartitionReassignmentsRequest.json =>
OffsetDeleteRequest.json} (53%)
 copy clients/src/main/resources/common/message/{EndTxnResponse.json => OffsetDeleteResponse.json}
(51%)


Mime
View raw message