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/10/13 15:59:55 UTC

[kafka] branch trunk updated (1457cc6 -> a72f0c1)

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 1457cc6  MINOR: Fix shouldNotResetEpochHistoryHeadIfUndefinedPassed (#9218)
     add a72f0c1  KAFKA-10533; KafkaRaftClient should flush log after appends (#9352)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/network/RequestChannel.scala  | 11 ++--
 .../main/scala/kafka/network/SocketServer.scala    | 18 +++--
 .../main/scala/kafka/raft/KafkaMetadataLog.scala   | 16 ++++-
 .../main/scala/kafka/tools/TestRaftServer.scala    | 54 +--------------
 .../java/org/apache/kafka/raft/FollowerState.java  | 14 ++--
 .../org/apache/kafka/raft/KafkaRaftClient.java     | 77 ++++++++++++----------
 .../java/org/apache/kafka/raft/LeaderState.java    | 21 ------
 .../java/org/apache/kafka/raft/ReplicatedLog.java  | 10 +++
 .../org/apache/kafka/raft/KafkaRaftClientTest.java |  5 +-
 .../test/java/org/apache/kafka/raft/MockLog.java   | 30 ++++++---
 .../java/org/apache/kafka/raft/MockLogTest.java    | 14 ++++
 .../apache/kafka/raft/RaftEventSimulationTest.java | 56 ++++++++++++++++
 12 files changed, 191 insertions(+), 135 deletions(-)