This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c671e44 MINOR: Add `KafkaAdminClient.getListOffsetsCalls` benchmark
(#10955)
add e00c0f3 KAFKA-12234: Implement request/response for offsetFetch
batching (KIP-709) (#10962)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../internals/ListConsumerGroupOffsetsHandler.java | 10 +-
.../consumer/internals/ConsumerCoordinator.java | 26 +-
.../kafka/common/requests/OffsetFetchRequest.java | 170 ++++++++++-
.../kafka/common/requests/OffsetFetchResponse.java | 131 +++++++-
.../common/message/OffsetFetchRequest.json | 26 +-
.../common/message/OffsetFetchResponse.json | 49 ++-
.../ListConsumerGroupOffsetsHandlerTest.java | 8 +-
.../apache/kafka/common/message/MessageTest.java | 242 ++++++++++++++-
.../common/requests/OffsetFetchRequestTest.java | 194 +++++++++---
.../common/requests/OffsetFetchResponseTest.java | 331 +++++++++++++++++----
.../kafka/common/requests/RequestResponseTest.java | 147 +++++++--
core/src/main/scala/kafka/server/KafkaApis.scala | 173 +++++++----
.../kafka/api/AuthorizerIntegrationTest.scala | 215 ++++++++++++-
.../unit/kafka/server/OffsetFetchRequestTest.scala | 237 +++++++++++++++
15 files changed, 1701 insertions(+), 260 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala
