This is an automated email from the ASF dual-hosted git repository.
satishd pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 6b9ea764566 KAFKA-17057: Add RETRY option to
ProductionExceptionHanlder (#17163)
add 560076ba9e8 KAFKA-15859: Add timeout field to the ListOffsets request
(#17112)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 2 +-
.../admin/internals/ListOffsetsHandler.java | 9 ++++--
.../clients/consumer/internals/OffsetFetcher.java | 7 +++--
.../consumer/internals/OffsetsRequestManager.java | 7 +++--
.../kafka/common/requests/ListOffsetsRequest.java | 9 ++++++
.../common/message/ListOffsetsRequest.json | 8 ++++--
.../common/message/ListOffsetsResponse.json | 4 ++-
.../admin/internals/ListOffsetsHandlerTest.java | 32 ++++++++++++++++++----
.../internals/FetchRequestManagerTest.java | 4 +--
.../clients/consumer/internals/FetcherTest.java | 2 +-
.../consumer/internals/OffsetFetcherTest.java | 4 ++-
.../internals/OffsetsRequestManagerTest.java | 32 ++++++++++++++++++++++
.../common/requests/ListOffsetsRequestTest.java | 1 +
core/src/main/scala/kafka/server/KafkaApis.scala | 2 +-
.../main/scala/kafka/server/ReplicaManager.scala | 7 +++--
.../java/kafka/test/annotation/ClusterTest.java | 2 +-
.../scala/unit/kafka/server/KafkaApisTest.scala | 9 ++++--
.../kafka/server/common/MetadataVersion.java | 9 ++++--
.../kafka/server/common/MetadataVersionTest.java | 14 ++++++++++
19 files changed, 132 insertions(+), 32 deletions(-)
