[kafka] branch trunk updated (a46c07e -> 634c917)

[jg...@apache.org]

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 a46c07e  KAFKA-10292: Set min.insync.replicas to 1 of __consumer_offsets (#9286)
     add 634c917  KAFKA-10435; Fetch protocol changes for KIP-595 (#9275)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/consumer/internals/Fetcher.java  |   3 +-
 .../apache/kafka/common/requests/FetchRequest.java |  93 +++++++---
 .../kafka/common/requests/FetchResponse.java       |  23 +++
 .../resources/common/message/FetchRequest.json     |  10 +-
 .../resources/common/message/FetchResponse.json    |  15 +-
 core/src/main/scala/kafka/api/ApiVersion.scala     |  11 +-
 core/src/main/scala/kafka/cluster/Partition.scala  |  35 +++-
 core/src/main/scala/kafka/log/Log.scala            |   1 +
 .../src/main/scala/kafka/server/DelayedFetch.scala |  16 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  25 ++-
 .../scala/kafka/server/ReplicaFetcherThread.scala  |   3 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |  23 ++-
 .../checkpoints/LeaderEpochCheckpointFile.scala    |   4 +-
 .../kafka/server/epoch/LeaderEpochFileCache.scala  | 193 ++++++++++++---------
 .../kafka/server/DelayedFetchTest.scala            |   1 +
 .../scala/unit/kafka/cluster/PartitionTest.scala   |  77 +++++++-
 .../test/scala/unit/kafka/log/LogSegmentTest.scala |   2 +-
 .../scala/unit/kafka/server/FetchRequestTest.scala |  42 ++++-
 .../scala/unit/kafka/server/KafkaApisTest.scala    |   5 +-
 .../server/ReplicaAlterLogDirsThreadTest.scala     |   3 +
 .../server/epoch/LeaderEpochFileCacheTest.scala    |   2 +-
 21 files changed, 442 insertions(+), 145 deletions(-)