Google Git Google Git
Sign in
apache/kafka/HEAD
  1. a3444d8 MINOR: Stop staging LICENSE/NOTICE into kafka-site content dir (#23906) by Omnia Ibrahim · 10 hours ago trunk
  2. dbe15eb KAFKA-15853: [4/N] Move DynamicLogConfig and log config accessors to Java (#23662) by Christo Lolov · 10 hours ago
  3. 8b5fc1b MINOR: Make share group state partition metadata unmodifiable (#23888) by Sean Quah · 17 hours ago
  4. df536bd KAFKA-20404: Replace bulk DefaultStateUpdater atomicity excludes with field-level suppressions (#22333) by Lyphixia Wang · 20 hours ago
  5. 787c2b4 MINOR: Reject reserved client instance ID in GetTelemetrySubscriptions v0 (#23825) by Alan Lau · 24 hours ago
  6. 95621a0 MINOR: Break down TargetAssignmentBuilderBenchmark by builder (#23868) by Sean Quah · 24 hours ago
  7. c1b92ad MINOR: Fix RackAwareStandbyPicker javadoc on how tag keys are picked (#23889) by gabriellafu · 25 hours ago
  8. 9fbcd3f MINOR: Fixed typos in comments across multiple Java classes (#23875) by I-Chau (David) Wang · 33 hours ago
  9. 132ce70 KAFKA-21305 Bump Jackson version to 2.22.4 (#23862) by Gergely Harmadas · 33 hours ago
  10. a81c9e6 MINOR: Update document for KIP-1241 (#23520) by Jian · 33 hours ago
  11. db4700f KAFKA-21058 Simplify jsonNodeToInt and jsonNodeToLong (#23436) by Russole Chen · 33 hours ago
  12. 702446e KAFKA-12188 Assert specific connection failure in SaslAuthenticatorTest (#23485) by hysu · 34 hours ago
  13. 6adbf15 MINOR: Validate operation types in incremental config updates (#23822) by S.Y. Wang · 34 hours ago
  14. f45fc4b KAFKA-21258 Move the Docker image usage guide from docker/examples/README.md to the website docs (#23819) by Murali Basani · 34 hours ago
  15. 46dc4b5 KAFKA-21280: Do not send stale bytes after a failed file read in SslTransportLayer.transferFrom (#23832) by Mykyta Bozhenko · 2 days ago
  16. 0d82450 KAFKA-16304: Offline the log directory on a disk error in the zero-copy Fetch path (#23445) by Mykyta Bozhenko · 2 days ago
  17. 814cfa3 KAFKA-21181: Allow committing an empty transaction in TV2 (#23831) by Ritika Reddy · 2 days ago
  18. bfb092b KAFKA-20858: Refactor subscription state (#22996) by Andrew Schofield · 2 days ago
  19. e149305 KAFKA-21288: Add MirrorPartitionState (#23830) by Federico Valeri · 2 days ago
  20. 8e46092 KAFKA-12744: Upgrade argparse4j from 0.7.0 to 0.9.0 (#23796) by Dejan Stojadinović · 2 days ago
  21. f2f91b1 MINOR: Update documentation version references to 4.4 (#23869) by majialong · 3 days ago
  22. a0d918c KAFKA-21307: Add share group DLQ setup to ShareConsumeBenchSpec (#23867) by Sushant Mahajan · 3 days ago
  23. cf93eef KAFKA-21293 SubscriptionState#unsubscribe should not reset the rebalance listener (#23852) by Ken Huang · 3 days ago
  24. efe988d KAFKA-20391: Improve types returned by the Connect REST API (#22001) by gomudayya · 3 days ago
  25. f568b7b MINOR: Share one empty array between empty IntLists (#23861) by David Jacot · 3 days ago
  26. 2b5dfe2 KAFKA-20999: [1/N] Add RackAwareStandbyPicker for rack-aware standby placement (#23790) by gabriellafu · 3 days ago
  27. f908227 KAFKA-21257 Document tokenless OAUTHBEARER login for validate-only brokers (#23818) by Murali Basani · 3 days ago
  28. cc8baad MINOR: Fix login callback config cleanup in SaslAuthenticatorTest (#23746) by SunMin Lee · 4 days ago
  29. 6556669 MINOR: Don't block on position() when advancing standby restored offsets (#23841) by Bill Bejeck · 6 days ago
  30. 59046ae KAFKA-21289 Fix release.py stage-docs for Hugo kafka-site (#23833) by Omnia Ibrahim · 6 days ago
  31. b35ed0e KAFKA-21214: [6/N] Add the balance step of the uniform2 assignor (#23735) by David Jacot · 6 days ago
  32. f6f4cc0 KAFKA-21153 Add physical log deletion tests to DeleteTopicTest (#23827) by Kuan-Po Tseng · 6 days ago
  33. 34f859e KAFKA-21268: Replace temp file handler with JUnit 5 @TempDir in server, shell, and storage tests (#23810) by KhyatiVaghamshi · 6 days ago
  34. e09cc63 KAFKA-20684 [8/N]: Migrate clients tests to RebalanceListener (#23108) by Aditya Kousik · 6 days ago
  35. f7a6dfe MINOR: Migrate PlaintextConsumerAssignorsTest to Java (#23708) by Andy Huang · 6 days ago
  36. b2f8536 KAFKA-14302: Advance restored offsets after changelog catch-up (#23298) by Ramu · 6 days ago
  37. dfd3dca KAFKA-21253: Always clear record collector offsets in closeDirty (#23791) by Bill Bejeck · 7 days ago
  38. 383388b KAFKA-15976 Follow-up fixes for initial offsets on connector creation (#23783) by Pranav Siby · 7 days ago
  39. 3d1e3f5 KAFKA-21214: [5/N] Move the steps of the uniform2 assignor to a subpackage (#23823) by David Jacot · 7 days ago
  40. 2f1f34d KAFKA-21111 [2/N]: Grant tasks at once to members that cannot be warmed up (#23784) by Lucas Brutschy · 7 days ago
  41. 4abb5a2 KAFKA-21153: Remove the wait file cleanup logic in ClusterInstance#waitTopicDeletion (#23800) by Kuan-Po Tseng · 7 days ago
  42. 292ad36 KAFKA-21214: [3/N] Add the quotas and the first two steps of the uniform2 assignor (#23733) by David Jacot · 7 days ago
  43. 8c01227 MINOR: Replace try/fail/catch with assertThrows in remaining Streams tests (#23636) by SunMin Lee · 7 days ago
  44. e2c58a0 KAFKA-21223: Add topic-level configs (#23782) by Federico Valeri · 7 days ago
  45. e58847b MINOR: Prevent swallowing exceptions in MetricsDuringTopicCreationDeletionTest (#23704) by Yen-Ting Li · 8 days ago
  46. ca08bdc MINOR: Limit ConsoleConsumerTest to KRaft mode only (#23690) by hysu · 8 days ago
  47. 27801d7 KAFKA-21222 Add broker-level configs (part 2) (#23797) by Federico Valeri · 8 days ago
  48. b766503 MINOR: update upgrade.md on rack config (#23817) by gabriellafu · 8 days ago
  49. b9b0c90 MINOR: Add optional acknowledgeType to ShareConsumeBenchSpec (#23802) by Sushant Mahajan · 8 days ago
  50. abc2906 MINOR: Address 4.4 documentation gaps for Streams and OAuth (#23809) by Lucy Liu · 8 days ago
  51. 515a8c5 KAFKA-20924: Use Request Header v3 for GetTelemetrySubscriptions and PushTelemetry v1 (#23651) by Alan Lau · 8 days ago
  52. 54026bc KAFKA-21214: [4/N] Build IndexedGroup with IndexedGroup.Builder (#23801) by David Jacot · 8 days ago
  53. 0e7f9c7 KAFKA-21265 Handle raw string values when describing topic configs (#23785) by Gaurav Narula · 8 days ago
  54. eabf518 KAFKA-21274: Remove unused javax jaxb-api and activation dependencies (#23808) by Gergely Harmadas · 8 days ago
  55. 03e6606 MINOR: Document thread-safety of PartitionAssignor (#23795) by David Jacot · 9 days ago
  56. 4d4cc7c KAFKA-19979: Improve Kafka Streams config files (#22831) by Peter Huang · 9 days ago
  57. 43c014d KAFKA-19804: Improve heartbeat request manager initial HB interval (#23687) by Kuan-Po Tseng · 9 days ago
  58. 5f684cc KAFKA-21255: Return Streams assignments when all owned task sets are reported. (#23768) by ChickenchickenLove · 9 days ago
  59. 3a2eecc MINOR: Remove duplicate test dependency declarations (#23786) by Ayoub · 9 days ago
  60. 24ce9e6 KAFKA-21194 [1/N]: Place active tasks with the Sainte-Laguë method in the balanced assignor (#23755) by Gavin Wang · 9 days ago
  61. 0661cd0 KAFKA-21212: Fix rack ID removal on Streams static member rejoin. (#23705) by ChickenchickenLove · 9 days ago
  62. 4a8164b KAFKA-21111 [1/N]: Tell the refiner which members may be given a warm-up task (#23761) by Lucas Brutschy · 9 days ago
  63. 3946884 KAFKA-21214: [2/N] Add the indexed group of the uniform2 assignor (#23732) by David Jacot · 9 days ago
  64. e4e8654 KAFKA-21264: Javadoc output language depends on the build machine's system locale (#23789) by Russole Chen · 9 days ago
  65. 65a04de MINOR: Remove unused jmhCoreBenchmarks and spotbugs library entries (#23793) by Gergely Harmadas · 9 days ago
  66. 740c90e KAFKA-21019 Add consumer and share group protocol test cases to Docker sanity tests (#23427) by majialong · 9 days ago
  67. c7cc6d4 KAFKA-15853: [3/N] Move DynamicReplicationConfig to Java (#23661) by Christo Lolov · 10 days ago
  68. 91dcfac KAFKA-21235 The docs of sleepSecsOpt should state it is in seconds (#23787) by Russole Chen · 10 days ago
  69. a2141d8 KAFKA-20278 : Refactor - Remaining HeadersStoreUpgradeIntegrationTest cleanups, [3/3] (#23738) by Murali Basani · 10 days ago
  70. bbfcdcb KAFKA-20684 [4/N]: Migrate Connect to RebalanceListener (#23105) by Aditya Kousik · 10 days ago
  71. f329565 KAFKA-21222: Add broker-level configs for Cluster Mirroring (#23729) by Federico Valeri · 10 days ago
  72. cd69d2e KAFKA-14333 Document PolicyViolationException in Admin#deleteRecords javadoc (#23716) by rishi-rana · 11 days ago
  73. a0ad457 MINOR: Add SASL and SSL section in docker docs (#23751) by Murali Basani · 11 days ago
  74. b0a2ca3 KAFKA-21143 Server-only OAUTHBEARER listener with private JWKS CA triggers token login and fails broker startup (#23557) by Murali Basani · 11 days ago
  75. 32397d9 KAFKA-21110 Document that min.insync.replicas is bounded by the replica count (#23529) by Lucy Liu · 11 days ago
  76. 2e4d25e MINOR: Allow overriding the base image of the JVM Docker image (#23560) by Maros Orsak · 11 days ago
  77. 3de09ca MINOR: Add PR description guidance to AGENTS.md (#23739) by Sean Quah · 12 days ago
  78. 3b9335d MINOR: Add warm-up tests for coordinator failover, owner departure and multi-threaded members (#23675) by Lucas Brutschy · 13 days ago
  79. b37898c KAFKA-15976: Allow specifying initial offsets while creating connectors - KIP-995 (#23268) by Pranav Siby · 13 days ago
  80. eb8e911 KAFKA-21158: Document retention impact of future timestamps allowed by message.timestamp.after.max.ms (#23596) by Murali Basani · 13 days ago
  81. 5a52d8d MINOR: Clean up Streams header adapter tests after KAFKA-20224 (#23727) by Alieh Saeedi · 13 days ago
  82. dca3816 KAFKA-21119: Replace temp file handler with JUnit 5 @TempDir in generator, tools, and test-common (#23381) by KhyatiVaghamshi · 13 days ago
  83. 4151a81 KAFKA-21026: Add JMH benchmark for the streams assignment refiner (#23616) by Gavin Wang · 13 days ago
  84. 3c1b3f2 MINOR: Add broker integration tests for classic JoinGroup topology cleanup (#23747) by Lucas Brutschy · 13 days ago
  85. 9dfd65d KAFKA-21181: Return NOT_COORDINATOR from a stale transaction coordinator cache (#23630) by Ritika Reddy · 14 days ago
  86. c553733 MINOR: Add broker integration tests for topology-description plugin failure surfacing (#23670) by Lucas Brutschy · 14 days ago
  87. 5e318af KAFKA-21118: Replace temp file handler with JUnit 5 @TempDir in connect tests (#23280) by KhyatiVaghamshi · 2 weeks ago
  88. 0e3533b MINOR: Remove redundant tools test-common-util dependency (#23745) by Edmond Abraham · 2 weeks ago
  89. bf8a027 MINOR: Fix BackgroundConsumerSet.start() returning before all consumers have joined (#23702) by Sean Quah · 2 weeks ago
  90. ad038ef KAFKA-21038 Replace LogManagerBuilder with direct LogManager constructor calls (#23385) by Chang-Chi Hsu · 2 weeks ago
  91. b234a3a KAFKA-18477 Remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (#23318) by Ken Huang · 2 weeks ago
  92. 2142c21 KAFKA-21237 Remove accidental JUnit 4 usage (#23741) by Gergely Harmadas · 2 weeks ago
  93. 2f4b948 KAFKA-21120: Replace temp file handler with JUnit 5 @TempDir in clients and connect tests (#23388) by KhyatiVaghamshi · 2 weeks ago
  94. 120f142 KAFKA-15104: Fix flaky tests in MetadataQuorumCommandTest (#23531) by Tamas Barnabas Egyed · 2 weeks ago
  95. baa35b5 KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable (#23165) by gabriellafu · 2 weeks ago
  96. 85387e9 KAFKA-21088: Restore PUSH_NEEDED when telemetry payload construction fails (#23590) by nileshkumar3 · 2 weeks ago
  97. bce1287 KAFKA-21152 LogCompactionTester should read until the end offsets instead of stopping at an empty poll (#23572) by Eric Chang · 2 weeks ago
  98. 4a0ae51 MINOR: Metadata cluster check enabled for admin (#23678) by Andrew Schofield · 2 weeks ago
  99. b71243d KAFKA-21214: [1/N] Add primitive collections for the uniform2 assignor (#23722) by David Jacot · 2 weeks ago
  100. 54152f7 MINOR: Add streams group integration tests for the warm-up task lifecycle (#23620) by Lucas Brutschy · 2 weeks ago