10 Pull requests merged by 7 people

• KAFKA-19005: improve the documentation of DescribeTopicsOptions#partitionSizeLimitPerResponse

  #19268 merged Mar 28, 2025

• KAFKA-19036: Rewrite LogAppendTimeTest and move it to storage module

  #19282 merged Mar 28, 2025

• KAFKA-19049: Remove the @ExtendWith(ClusterTestExtensions.class) from code base

  #19299 merged Mar 28, 2025

• MINOR: Refactor GroupCoordinator write path

  #19290 merged Mar 27, 2025

• MINOR: Mark streams RPCs as unstable

  #19292 merged Mar 27, 2025

• MINOR: Some cleanups in group coordinator's intergration tests

  #19281 merged Mar 27, 2025

• MINOR: Remove stray printStackTrace from RequestConvertToJsonTest

  #19287 merged Mar 27, 2025

• KAFKA-17830: Cover unit tests for TBRLMM init failure scenarios

  #19076 merged Mar 27, 2025

• KAFKA-14486: Move LogCleanerManager to storage module

  #19216 merged Mar 27, 2025

• KAFKA-18827: Initialize share group state group coordinator impl. [3/N]

  #19026 merged Mar 26, 2025

19 Pull requests opened by 14 people

• KAFKA-16894: Define features to enable share groups

  #19293 opened Mar 26, 2025

• MINOR: Add check in ShareConsumerImpl to send acknowledgements of control records when ShareFetch is empty.

  #19295 opened Mar 26, 2025

• KAFKA-19047: Broker registrations are slow if previously fenced or shutdown

  #19296 opened Mar 27, 2025

• KAFKA-19048: Minimal Movement Replica Balancing algorithm

  #19297 opened Mar 27, 2025

• KAFKA-19042: [4/N] Move PlaintextConsumerCallbackTest to client-integration-tests module

  #19298 opened Mar 27, 2025

• KAFKA-18390: Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder (1/N)

  #19300 opened Mar 27, 2025

• MINOR: Remove DeleteSegmentsByRetentionTimeTest#executeTieredStorageTest flaky annotation

  #19301 opened Mar 27, 2025

• KAFKA-14487: Move LogManager static methods/fields to storage module

  #19302 opened Mar 27, 2025

• KAFKA-16407: Fix foreign key INNER join on change of FK from/to a null value

  #19303 opened Mar 27, 2025

• KAFKA-15873: Filter topics before sorting

  #19304 opened Mar 28, 2025

• MINOR: Cleanup test-common-runtime module

  #19305 opened Mar 28, 2025

• KAFKA-18870 Implement describeDelegationToken for controller

  #19306 opened Mar 28, 2025

• KAFKA-17653 Update Scala version to 2.13.15 for support Java 23 (3.9 backport)

  #19307 opened Mar 28, 2025

• KAFKA-17722 Fix "this-escape" compiler warnings (BrokerTopicMetrics) …

  #19308 opened Mar 28, 2025

• KAFKA-17723 Fix "this-escape" compiler warnings (MultiThreadedEventPr…

  #19309 opened Mar 28, 2025

• KAFKA-17773 Upgrade spotbug to work under java 23 (3.9 backport)

  #19310 opened Mar 28, 2025

• WIP: Please ignore

  #19311 opened Mar 28, 2025

• KAFKA-18943: Update EosIntegrationTest for EOSv1

  #19312 opened Mar 29, 2025

• KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups`

  #19313 opened Mar 29, 2025

65 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream…

  #19275 commented on Mar 29, 2025 • 29 new comments

• KAFKA-18892: KIP-877 Add support for ClientQuotaCallback

  #19068 commented on Mar 28, 2025 • 7 new comments

• KAFKA-18962: Fix onBatchRestored call in GlobalStateManagerImpl

  #19188 commented on Mar 27, 2025 • 6 new comments

• KAFKA-18935: Ensure brokers do not return null records in FetchResponse

  #19167 commented on Mar 28, 2025 • 6 new comments

• KAFKA-18826: Add global thread metrics

  #18953 commented on Mar 27, 2025 • 6 new comments

• KAFKA-10409: Refactor Kakfa Streams RocksDB Iterators

  #18610 commented on Mar 28, 2025 • 5 new comments

• KAFKA-14523: Move DelayedRemoteListOffsets to the storage module

  #19285 commented on Mar 28, 2025 • 4 new comments

• MINOR: Revert migrate LogFetchInfo, Assignment and RequestAndCompletionHandler to java record

  #19177 commented on Mar 29, 2025 • 4 new comments

• KAFKA-19004:Move DelayedDeleteRecords to server-common module

  #19226 commented on Mar 28, 2025 • 4 new comments

• KAFKA-17662: config.providers configuration missing from the docs

  #18930 commented on Mar 29, 2025 • 3 new comments

• KAFKA-18409: ShareGroupStateMessageFormatter should use CoordinatorRecordMessageFormatter

  #18510 commented on Mar 29, 2025 • 3 new comments

• KAFKA-19001: Use streams group-level configurations in heartbeat

  #19219 commented on Mar 27, 2025 • 3 new comments

• KAFKA-16729: Support isolation level for share consumer

  #19261 commented on Mar 28, 2025 • 3 new comments

• KAFKA-18067: Add a flag to disable producer reset during active task creator shutting down

  #19269 commented on Mar 29, 2025 • 3 new comments

• KAFKA-19042: [1/N] Move ConsumerTopicCreationTest to client-integration-tests module

  #19283 commented on Mar 29, 2025 • 3 new comments

• MINOR: migrate BrokerCompressionTest to storage module

  #19277 commented on Mar 27, 2025 • 2 new comments

• MINOR: Specify 2.1 as the minimum broker version for clients

  #19250 commented on Mar 27, 2025 • 2 new comments

• [WIP] KAFKA-14830: Illegal state error in transactional producer

  #17022 commented on Mar 26, 2025 • 1 new comment

• MINOR: Cleanup metadata module

  #18937 commented on Mar 29, 2025 • 1 new comment

• KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager

  #19286 commented on Mar 27, 2025 • 1 new comment

• KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread.

  #19231 commented on Mar 29, 2025 • 0 new comments

• (WIP) KAFKA-18390: Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder

  #19222 commented on Mar 29, 2025 • 0 new comments

• KAFKA-17078: Add SecurityManagerCompatibility shim (#16522)

  #19221 commented on Mar 28, 2025 • 0 new comments

• KAFKA-17715: Remove argument force_use_zk_connection from e2e

  #19209 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18982: Allow ClusterTests to ignore specific thread leaks

  #19206 commented on Mar 26, 2025 • 0 new comments

• MINOR: Write log differently according to the size of missingListenerPartitions

  #11418 commented on Mar 27, 2025 • 0 new comments

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 commented on Mar 29, 2025 • 0 new comments

• MINOR: Run CI with Java 24 and update documentation (instead of 23)

  #19235 commented on Mar 28, 2025 • 0 new comments

• KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch

  #19236 commented on Mar 29, 2025 • 0 new comments

• KAFKA-19008 Remove scala version from artifacts

  #19241 commented on Mar 27, 2025 • 0 new comments

• MINOR: Add doc for configuration parameters to keep the format consistent

  #19244 commented on Mar 27, 2025 • 0 new comments

• MINOR UnifiedLog topic-partition as attribute as it is stable

  #19253 commented on Mar 28, 2025 • 0 new comments

• KAFKA-18960: The default type of ssh key used by vagrant is disabled …

  #19264 commented on Mar 29, 2025 • 0 new comments

• KAFKA-12744: dependency upgrade: `argparse4j` 0.7.0 -->> 0.9.0

  #19265 commented on Mar 28, 2025 • 0 new comments

• KAFKA-19032: Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames

  #19270 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18959: increase the num_workers from 9 to 12

  #19274 commented on Mar 27, 2025 • 0 new comments

• KAFKA-19003-Add forceTerminateTransaction command to CLI tools

  #19276 commented on Mar 28, 2025 • 0 new comments

• MINOR: remove transform and through from repartition description

  #19291 commented on Mar 27, 2025 • 0 new comments

• KAFKA-14464: Make resource leaks for MM2 resources more difficult

  #12980 commented on Mar 27, 2025 • 0 new comments

• fix: replace an inefficient loop in kafka internals

  #13162 commented on Mar 27, 2025 • 0 new comments

• KAFKA-13152: Kip 770 buffer size fix

  #13283 commented on Mar 27, 2025 • 0 new comments

• KAFKA-16394: Fix null propagation in foreign key join result

  #15607 commented on Mar 27, 2025 • 0 new comments

• MINOR: migrate SaslClientsWithInvalidCredentialsTest to use ClusterTestExtensions

  #16225 commented on Mar 28, 2025 • 0 new comments

• [Don't Merge] Test

  #16463 commented on Mar 27, 2025 • 0 new comments

• KAFKA-16907: Fix RaftUtil's type complexity

  #16831 commented on Mar 29, 2025 • 0 new comments

• KAFKA-17423 Trie implementation

  #17087 commented on Mar 28, 2025 • 0 new comments

• KAFKA-16758: Extend Consumer#close with an option to leave the group or not

  #17614 commented on Mar 29, 2025 • 0 new comments

• KAFKA-17601: Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags

  #17731 commented on Mar 28, 2025 • 0 new comments

• KAFKA-17871: avoid blocking the herder thread when producer flushing hangs

  #18142 commented on Mar 28, 2025 • 0 new comments

• KAFKA-18336: Improve jmh tests on ACL in AuthorizerBenchmark and StandardAuthorizerUpdateBenchmark

  #18293 commented on Mar 29, 2025 • 0 new comments

• KAFKA-16260: Deprecate window.size.ms and window.inner.class.serde in StreamsConfig

  #18297 commented on Mar 26, 2025 • 0 new comments

• MINOR: Cleanup build.gradle unused import and update the deprecated `archivePath`

  #18537 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol

  #18600 commented on Mar 29, 2025 • 0 new comments

• KAFKA-10844: groupBy without shuffling

  #18811 commented on Mar 29, 2025 • 0 new comments

• [WIP] JWT bearer grant type support

  #18912 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18834 Fix LoggingResourceTest#testSetLevelDefaultScope

  #18972 commented on Mar 27, 2025 • 0 new comments

• KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests

  #18987 commented on Mar 27, 2025 • 0 new comments

• KAFKA-17218: kafka-consumer-groups should handle describe groups with deleted topics

  #19029 commented on Mar 29, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18607: Update jfreechart dependency

  #19074 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups

  #19093 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18923: resource leak in RSM fetchIndex inputStream

  #19111 commented on Mar 29, 2025 • 0 new comments

• KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator

  #19114 commented on Mar 26, 2025 • 0 new comments

• KAFKA-15931: Cancel RemoteLogReader gracefully

  #19150 commented on Mar 28, 2025 • 0 new comments

• KAFKA-18613: Improve test coverage for missing topics

  #19189 commented on Mar 26, 2025 • 0 new comments