You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jg...@apache.org on 2020/09/16 16:06:35 UTC

[kafka] branch trunk updated (f28713f -> aa5263f)

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 f28713f  MINOR: Add unit tests for StreamsRebalanceListener (#9258)
     add aa5263f  KAFKA-10487; Fetch response should return diverging epoch and end offset (#9290)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/requests/FetchResponse.java       | 20 +++++-----
 .../resources/common/message/FetchResponse.json    |  8 +++-
 core/src/main/scala/kafka/cluster/Partition.scala  |  9 ++++-
 core/src/main/scala/kafka/log/Log.scala            |  3 +-
 .../src/main/scala/kafka/server/DelayedFetch.scala |  2 +-
 core/src/main/scala/kafka/server/KafkaApis.scala   |  4 +-
 .../main/scala/kafka/server/ReplicaManager.scala   | 22 +++++------
 .../kafka/server/DelayedFetchTest.scala            |  2 +-
 .../scala/unit/kafka/cluster/PartitionTest.scala   | 43 ++++++++++++++++------
 .../scala/unit/kafka/server/FetchRequestTest.scala |  7 +++-
 .../server/ReplicaAlterLogDirsThreadTest.scala     |  6 +--
 11 files changed, 80 insertions(+), 46 deletions(-)