48 Pull requests merged by 28 people

• MINOR: add boundary IT for delivery count

  #19649 merged May 6, 2025

• MINOR: support ipv6 in ducker-ak

  #19537 merged May 6, 2025

• MINOR; Log message for unexpected buffer allocation

  #19596 merged May 6, 2025

• KAFKA-19218: Add missing leader epoch to share group state summary response

  #19602 merged May 6, 2025

• MINOR: Small cleanups in clients tests

  #19634 merged May 6, 2025

• KAFKA-19207: Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module

  #19574 merged May 6, 2025

• KAFKA-19170 Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module

  #19528 merged May 6, 2025

• MINOR: Convert streams group options to consumer group options in Admin APIs

  #19583 merged May 6, 2025

• MINOR: Improve output for delete-offset of kafka-consumer-groups.sh

  #19610 merged May 6, 2025

• MINOR: Bump templateData.js version

  #19648 merged May 6, 2025

• KAFKA-19227: Piggybacked share fetch acknowledgements performance issue

  #19612 merged May 6, 2025

• MINOR: exclude error_prone_annotations lib from caffeine dependency

  #19638 merged May 6, 2025

• MINOR: improve AdjustStreamThreadCountTest

  #19617 merged May 5, 2025

• KAFKA-19216: Eliminate flakiness in kafka.server.share.SharePartitionTest

  #19639 merged May 5, 2025

• KAFKA-19133: Support fetching for multiple remote fetch topic partitions in a single share fetch request

  #19592 merged May 5, 2025

• KAFKA-18537: Fix flaky RemoteIndexCacheTest#testCleanerThreadShutdown

  #19628 merged May 5, 2025

• KAFKA-19240: Move MetadataVersionIntegrationTest to clients-integration-tests module

  #19641 merged May 5, 2025

• KAFKA-19232: Handle Share session limit reached exception in clients.

  #19619 merged May 4, 2025

• KAFKA-19131: Adjust remote storage reader thread maximum pool size to avoid illegal argument

  #19629 merged May 4, 2025

• MINOR: replace .stream().forEach() with .forEach()

  #19626 merged May 4, 2025

• KAFKA-19060 Documented null edge cases in the Clients API JavaDoc

  #19393 merged May 4, 2025

• KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout

  #19578 merged May 3, 2025

• KAFKA-18267: Add unit tests for CloseOptions

  #19571 merged May 3, 2025

• MINOR: Change info log to debug for scheduled timer tasks.

  #19624 merged May 3, 2025

• MINOR: fix bug in MockConsumer

  #19627 merged May 3, 2025

• MINOR: Remove unnecessary Optional from offsetsToSnapshot

  #19613 merged May 3, 2025

• KAFKA-19204: Allow persister retry of initializing topics.

  #19603 merged May 2, 2025

• MINOR: remove @FunctionalInterface annotation

  #19618 merged May 2, 2025

• MINOR: use isEmpty() to avoid compiler warning

  #19616 merged May 2, 2025

• MINOR: Move AdminCommandFailedException and AdminOperationException to tools module

  #19614 merged May 2, 2025

• KAFKA-19146: Merge OffsetAndEpoch from raft to server-common

  #19475 merged May 1, 2025

• KAFKA-16894: Correct definition of ShareVersion

  #19606 merged May 1, 2025

• KAFKA-19073: add transactional ID pattern filter to ListTransactions

  #19355 merged May 1, 2025

• MINOR: printing share group describe result in sorted order

  #19599 merged May 1, 2025

• KAFKA-17541:[1/2] Improve handling of delivery count

  #19430 merged May 1, 2025

• KAFKA-19015: Remove share session from cache on share consumer connection drop

  #19329 merged May 1, 2025

• KAFKA-19169: Enhance AuthorizerIntegrationTest for share group APIs

  #19540 merged May 1, 2025

• MINOR: fix bug in TimeWindowedDeserializerTest

  #19570 merged May 1, 2025

• MINOR: Improve docs for client group configs

  #19605 merged Apr 30, 2025

• MINOR: Move candidateClients set creation outside of task loop for StickyTaskAssignor

  #19511 merged Apr 30, 2025

• KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test

  #19604 merged Apr 30, 2025

• KAFKA-16718-4/n: ShareGroupCommand changes for DeleteShareGroupOffsets admin call

  #19587 merged Apr 30, 2025

• KAFKA-19210: resolved the flakiness in testShareGroupHeartbeatInitializeOnPartitionUpdate

  #19601 merged Apr 30, 2025

• MINOR; Log remote replica id when rejecting vote

  #19600 merged Apr 30, 2025

• KAFKA-16894: Exploit share feature [3/N]

  #19542 merged Apr 30, 2025

• HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest

  #19597 merged Apr 30, 2025

• KAFKA-19202: Enable KIP-1071 in streams_broker_down_resilience_test

  #19594 merged Apr 30, 2025

• KAFKA-19173: Add Feature for "streams" group

  #19509 merged Apr 30, 2025

28 Pull requests opened by 25 people

• KAFKA-19215: Handle share partition fetch lock cleanly using tokens

  #19598 opened Apr 30, 2025

• KAFKA-19221: Propagate IOException on LogSegment#close

  #19607 opened Apr 30, 2025

• KAFKA-19182: Move SchedulerTest to server module

  #19608 opened Apr 30, 2025

• KAFKA-19214: Clean up use of Optionals in RequestManagers.entries()

  #19609 opened May 1, 2025

• KAFKA-17747: [3/N] Get rid of TopicMetadata in SubscribedTopicDescriberImpl

  #19611 opened May 1, 2025

• KAFKA-19097: Fix assertEquals arguement order in InternalStreamsBuilderTest

  #19615 opened May 1, 2025

• KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder)

  #19621 opened May 2, 2025

• KAFKA-18847: Refactor OAuth layer to improve reusability 1/N

  #19622 opened May 2, 2025

• (WIP)KAFKA-19203 Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient

  #19623 opened May 2, 2025

• KAFKA-19202: Enable KIP-1071 in streams_standby_replica_test.py

  #19625 opened May 2, 2025

• KAFKA-19145: Move LeaderEndPoint to Server module

  #19630 opened May 3, 2025

• KAFKA-19242: Fix commit bugs caused by race condition during rebalancing.

  #19631 opened May 4, 2025

• KAFKA-18695: Remove quorum=kraft from all integration tests

  #19633 opened May 4, 2025

• KAFKA-19234: broker should return UNAUTHORIZATION error for non-existing topic in produce request

  #19635 opened May 4, 2025

• Refactored DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation

  #19636 opened May 4, 2025

• KAFKA-19231: Handle fetch request when share session cache is full

  #19637 opened May 5, 2025

• KAFKA-19241: Updated tests in ShareFetchAcknowledgeRequestTest to reuse the socket for subsequent requests

  #19640 opened May 5, 2025

• MINOR: Simplify OffsetFetchResponse

  #19642 opened May 5, 2025

• MINOR; Add `--standalone --ignore-formatted` formatter test

  #19643 opened May 5, 2025

• [KAFKA-18905] Flaky-test fixes

  #19644 opened May 5, 2025

• MINOR: introduce structure to keep member assignment with topic Ids

  #19645 opened May 5, 2025

• KAFKA-19244: Add support for kafka-streams-groups.sh options (delete group, offset-related APIs) [1/2]

  #19646 opened May 5, 2025

• KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test)

  #19647 opened May 6, 2025

• KAFKA-19220: Add tests to ensure the internal configs don't return by public APIs by default

  #19650 opened May 6, 2025

• KAFKA-19042: [8/N] Move BaseConsumerTest, SaslPlainPlaintextConsumerTest to client-integration-tests module

  #19651 opened May 6, 2025

• KAFKA-19209: Clarify index.interval.bytes impact on offset and time index

  #19652 opened May 6, 2025

• MINOR: Remove ConstantBrokerOrActiveKController

  #19654 opened May 6, 2025

• MINOR: Fix some Request toString methods

  #19655 opened May 6, 2025

63 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-19078: Implement automatic controller addition to cluster metadata partition

  #19589 commented on May 6, 2025 • 60 new comments

• KAFKA-18855: Slice API for MemoryRecords

  #19581 commented on May 6, 2025 • 25 new comments

• KAFKA-18185: remove internal.leave.group.on.close config

  #19400 commented on May 7, 2025 • 13 new comments

• MINOR: Improve docs for retries & cleanup

  #19595 commented on May 1, 2025 • 11 new comments

• KAFKA-17747: [2/N] Add compute topic and group hash

  #19523 commented on May 6, 2025 • 10 new comments

• KAFKA-19248: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests

  #18325 commented on May 7, 2025 • 9 new comments

• KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module

  #19582 commented on May 5, 2025 • 9 new comments

• [WIP]KAFKA-19080 The constraint on segment.ms is not enforced at topic level

  #19371 commented on May 5, 2025 • 8 new comments

• KAFKA-19212: Correct the unclean leader election metric calculation

  #19590 commented on May 7, 2025 • 7 new comments

• KAFKA-19087: Move TransactionState to transaction-coordinator module

  #19568 commented on May 7, 2025 • 7 new comments

• KAFKA-18666: Controller-side monitoring for broker shutdown and startup

  #19586 commented on May 7, 2025 • 5 new comments

• KAFKA-17897: Deprecate Admin.listConsumerGroups [2/N]

  #19508 commented on May 6, 2025 • 4 new comments

• KAFKA-19082:[3/4] Add prepare txn method (KIP-939)

  #19539 commented on May 7, 2025 • 4 new comments

• KAFKA-19160;KAFKA-19164; Improve performance of fetching stable offsets

  #19497 commented on May 3, 2025 • 2 new comments

• KAFKA-6629: parameterise SegmentedCacheFunctionTest for session key schemas

  #19404 commented on May 4, 2025 • 1 new comment

• KAFKA-19176: Update Transactional producer to translate retriable into abortable exceptions

  #19522 commented on May 1, 2025 • 1 new comment

• KAFKA-18904: [1/N] Change ListClientMetricsResources API to ListConfigResources (wip)

  #19493 commented on May 6, 2025 • 0 new comments

• KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka

  #19501 commented on May 7, 2025 • 0 new comments

• KAFKA-19171: Kafka Streams crashes with UnsupportedOperationException

  #19507 commented on May 6, 2025 • 0 new comments

• WIP: Test against Java 24

  #19514 commented on May 2, 2025 • 0 new comments

• KAFKA-14691; Add TopicId to OffsetFetch API

  #19515 commented on May 6, 2025 • 0 new comments

• KAFKA-18066: Fix mismatched StreamThread ID in log messages

  #19517 commented on May 3, 2025 • 0 new comments

• MINOR: Replaced internal KafkaConfig field in TransactionLogConfig

  #19482 commented on May 5, 2025 • 0 new comments

• [WIP]KAFKA-18896 add KIP-877 support for Login

  #19527 commented on May 5, 2025 • 0 new comments

• KAFKA-19109: Don't print null in kafka-metadata-quorum describe status

  #19543 commented on May 6, 2025 • 0 new comments

• KAFKA-19091: Fix race condition in DelayedFutureTest

  #19553 commented on May 2, 2025 • 0 new comments

• KAFKA-19201: Handle deletion of user topics part of share partitions.

  #19559 commented on May 5, 2025 • 0 new comments

• [WIP] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller

  #19566 commented on May 3, 2025 • 0 new comments

• KAFKA-19206: ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() previously failed

  #19569 commented on Apr 30, 2025 • 0 new comments

• KAFKA-19168: MirrorMaker kafka_metrics_count metric is always incorrect

  #19573 commented on May 7, 2025 • 0 new comments

• [WIP]KAFKA-17826 Consumer#offsetsForTimes should not return null value

  #19575 commented on May 4, 2025 • 0 new comments

• KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID

  #19577 commented on May 5, 2025 • 0 new comments

• [ KAFKA-17049 ] fix Incremental rebalances assign too many tasks for the same connector together

  #16486 commented on May 1, 2025 • 0 new comments

• KAFKA-16951 Notify TransactionManager of disconnects to proactively rediscover Coordinator

  #16390 commented on May 2, 2025 • 0 new comments

• Code optimization: Supplement the missing Override tag on the override method

  #11399 commented on May 5, 2025 • 0 new comments

• KAFKA-16907: Fix RaftUtil's type complexity

  #16831 commented on May 1, 2025 • 0 new comments

• KAFKA-17503: Fix incorrect calculation of poll-idle-ratio-avg for con…

  #17139 commented on May 2, 2025 • 0 new comments

• KAFKA-16505: Add source raw bytes in processorContex

  #17960 commented on May 4, 2025 • 0 new comments

• KAFKA-1826 [1/N]: Introducing GroupStore

  #17981 commented on Apr 30, 2025 • 0 new comments

• KAFKA-18299: Move connect data classes into a dedicated module

  #18256 commented on May 5, 2025 • 0 new comments

• KAFKA-18638 fix flasky testThrottledProducerConsumer.testThrottledProducerConsumer

  #18689 commented on May 1, 2025 • 0 new comments

• KAFKA-18171: Unexpected Change in bootstrap.servers Behavior After Upgrade to 3.8.0

  #18706 commented on May 7, 2025 • 0 new comments

• feat(clients): MemberToRemove accepting memberId field on constructor…

  #18738 commented on May 1, 2025 • 0 new comments

• KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets

  #18929 commented on May 5, 2025 • 0 new comments

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

  #18930 commented on May 4, 2025 • 0 new comments

• [WIP] MINOR: Enable auth test for new consumer

  #18947 commented on May 1, 2025 • 0 new comments

• KAFKA-4650: Add unit tests for GraphNode class

  #18951 commented on May 5, 2025 • 0 new comments

• KAFKA-18841: Enable to test docker image locally

  #19028 commented on May 6, 2025 • 0 new comments

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

  #19029 commented on May 6, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on May 7, 2025 • 0 new comments

• KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups

  #19093 commented on May 7, 2025 • 0 new comments

• KAFKA-17715: Remove argument force_use_zk_connection from e2e

  #19209 commented on Apr 30, 2025 • 0 new comments

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

  #19231 commented on May 7, 2025 • 0 new comments

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 commented on May 6, 2025 • 0 new comments

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

  #19236 commented on May 7, 2025 • 0 new comments

• KAFKA-19026: AlterConfigPolicy incompatibility between ZK mode and KR…

  #19263 commented on May 2, 2025 • 0 new comments

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

  #19275 commented on May 6, 2025 • 0 new comments

• MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest

  #19336 commented on May 3, 2025 • 0 new comments

• KAFKA-19070:: Adding task number to user provided client id to ensure each consumer has a unique client ID to avoid metric registration conflicts.

  #19341 commented on May 6, 2025 • 0 new comments

• MINOR: Cleanup Core Module- Scala Modules (1/n)

  #19380 commented on May 4, 2025 • 0 new comments

• KAFKA-2526: command line --producer-property wins

  #16492 commented on May 7, 2025 • 0 new comments

• MINOR: Only send endpoints to partitions on changes

  #19407 commented on Apr 30, 2025 • 0 new comments

• KAFKA-16913 - Support external schemas in JSONConverter

  #19449 commented on May 6, 2025 • 0 new comments