Public signup for this instance is disabled. Go to our Self serve sign up page to request an account.

  1. Sub-task KAFKA-13884
    KRaft Obsever are not required to flush on every append
  2. Sub-task KAFKA-13621
    Resign leader on network partition
  3. Sub-task KAFKA-13321
    Notify listener of leader change on registration
  4. Sub-task KAFKA-13165
    Validate node id, process role and quorum voters
  5. Sub-task KAFKA-13089
    Revisit the usage of BufferSuppliers in Kraft
  6. Sub-task KAFKA-13006
    Remove the method RaftClient.leaderAndEpoch
  7. Sub-task KAFKA-12992
    Make kraft configuration properties public
  8. Sub-task KAFKA-12982
    Notify listeners of raft client shutdowns
  9. Sub-task KAFKA-12968
    Add integration tests for "test-kraft-server-start"
  10. Sub-task KAFKA-12773
    Use UncheckedIOException when wrapping IOException
  11. Sub-task KAFKA-12631
    Support api to resign raft leadership
  12. Sub-task KAFKA-12607
    Allow votes to be granted in resigned state
  13. Sub-task KAFKA-12465
    Decide whether inconsistent cluster id error are fatal
  14. Sub-task KAFKA-12461
    Extend LogManager to cover the metadata topic
  15. Sub-task KAFKA-12460
    Raft should prevent truncation below high watermark
  16. Sub-task KAFKA-12459
    Improve raft simulation tests
  17. Sub-task KAFKA-12440
    ClusterId validation for Vote, BeginQourum and EndQuorum
  18. Sub-task KAFKA-12373
    Improve KafkaRaftClient handling of graceful shutdown
  19. Sub-task KAFKA-12333
    KafkaMetadataLog and MockLock should validate that appended epochs are monotonically
  20. Sub-task KAFKA-12331
    KafkaRaftClient should use the LEO when appending LeaderChangeMessage
  21. Sub-task KAFKA-12258
    Change the BatchAccumulator to split records into batches
  22. Sub-task KAFKA-12237
    Support non-routable quorum voter addresses
  23. Sub-task KAFKA-12181
    Loosen monotonic fetch offset validation by raft leader
  24. Sub-task KAFKA-12161
    Raft observers should not require an id to fetch
  25. Sub-task KAFKA-12158
    Consider better return type of RaftClient.scheduleAppend
  26. Sub-task KAFKA-10842
    Refactor raft outbound request channel
  27. Sub-task KAFKA-10828
    Consider using "acknowledged" over "endorsing" for voters which have recognized the current leader
  28. Sub-task KAFKA-10826
    Ensure raft io thread wakes up after linger expiration
  29. Sub-task KAFKA-10817
    Add clusterId validation to Fetch handling
  30. Sub-task KAFKA-10756
    Add missing unit test for `UnattachedState`
  31. Sub-task KAFKA-10677
    Complete fetches in purgatory immediately after raft leader resigns
  32. Sub-task KAFKA-10676
    Decide whether Raft listener callback errors are fatal
  33. Sub-task KAFKA-10661
    Add resigned state to raft state machine to preserve leader/epoch information
  34. Sub-task KAFKA-10655
    Raft leader should resign after write failures
  35. Sub-task KAFKA-10652
    Raft leader should flush accumulated writes after a min size is reached
  36. Sub-task KAFKA-10644
    Fix VotedToUnattached test error
  37. Sub-task KAFKA-10636
    Bypass log validation for writes to raft log
  38. Sub-task KAFKA-10634
    LeaderChangeMessage should include the leader as one of the voters
  39. Sub-task KAFKA-10632
    Raft client should push all committed data to listeners
  40. Sub-task KAFKA-10601
    Add linger semantics to raft
  41. Sub-task KAFKA-10594
    Enhance Raft exception handling
  42. Sub-task KAFKA-10533
    Add log flush semantics to simulation test
  43. Sub-task KAFKA-10527
    Voters should always initialize as followers
  44. Sub-task KAFKA-10526
    Explore performance impact of leader fsync deferral
  45. Sub-task KAFKA-10519
    Unit tests for VotedState
  46. Sub-task KAFKA-10511
    Fix minor behavior difference in `MockLog`
  47. Sub-task KAFKA-10492
    Core Raft implementation
  48. Sub-task KAFKA-10487
    Fix edge case in Raft truncation protocol
  49. Sub-task KAFKA-10435
    Fetch protocol changes for KIP-595
Refresh results