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%)
