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 2021/02/19 22:44:16 UTC

[kafka] branch trunk updated (b35ca43 -> bbf145b)

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 b35ca43  KAFKA-9274: Throw TaskCorruptedException instead of TimeoutException when TX commit times out (#10072)
     add bbf145b  KAFKA-10817; Add clusterId validation to raft Fetch handling (#10129)

No new revisions were added by this update.

Summary of changes:
 ...on.java => InconsistentClusterIdException.java} |  9 ++--
 .../org/apache/kafka/common/protocol/Errors.java   |  4 +-
 .../resources/common/message/FetchRequest.json     |  3 +-
 core/src/main/scala/kafka/raft/RaftManager.scala   |  1 +
 .../org/apache/kafka/raft/KafkaRaftClient.java     | 18 +++++++
 .../kafka/raft/KafkaRaftClientSnapshotTest.java    | 24 ++++-----
 .../org/apache/kafka/raft/KafkaRaftClientTest.java | 58 ++++++++++++++++------
 .../apache/kafka/raft/RaftClientTestContext.java   | 55 +++++++++++++++++---
 .../apache/kafka/raft/RaftEventSimulationTest.java |  3 ++
 9 files changed, 134 insertions(+), 41 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/{InvalidUpdateVersionException.java => InconsistentClusterIdException.java} (81%)