71 Pull requests merged by 37 people

• KAFKA-18700: Migrate SnapshotPath and Entry in LogHistory to record classes

  #19062 merged Mar 9, 2025

• MINOR: Adjust ToC of zk2kraft and fix wrong section number of docker

  #19146 merged Mar 9, 2025

• MINOR: Fix missing argument in kafka-features.sh upgrade doc

  #19160 merged Mar 7, 2025

• KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsResponse

  #19127 merged Mar 7, 2025

• MINOR: Small fit and finish changes to Producer config doc strings

  #19125 merged Mar 7, 2025

• KAFKA-18940: fix electionWasClean

  #19156 merged Mar 7, 2025

• MINOR: Wrapping exceptions in usage for groups and metrics utility

  #19151 merged Mar 7, 2025

• MINOR: Allow for scheduling delay for periodic tasks to be configurable when ControllerResult.response = true

  #19143 merged Mar 7, 2025

• KAFKA-18285: Add describeStreamsGroup to Admin API

  #19116 merged Mar 7, 2025

• KAFKA-18461: Fix potential NPE in setDelta after map is erased

  #18684 merged Mar 7, 2025

• KAFKA-17607: Add CI step to verify LICENSE-binary

  #18299 merged Mar 7, 2025

• KAFKA-18929: Log a warning when time based segment delete is blocked by a future timestamp

  #19137 merged Mar 7, 2025

• KAFKA-15931: Reopen TransactionIndex if channel is closed

  #15241 merged Mar 7, 2025

• KAFKA-18046; High CPU usage when using Log4j2

  #19138 merged Mar 7, 2025

• MINOR: zk2kraft: add more information about kafka-configs.sh

  #19100 merged Mar 7, 2025

• KAFKA-18915: Migrate AdminClientRebootstrapTest to use new test infra

  #19094 merged Mar 6, 2025

• MINOR: reduce per-batch logging to TRACE level

  #19101 merged Mar 6, 2025

• KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer

  #19077 merged Mar 6, 2025

• KAFKA-18900: Experimental share consumer acknowledge mode config

  #19113 merged Mar 6, 2025

• MINOR Increase JUnit max forks and memory for CI

  #18560 merged Mar 6, 2025

• KAFKA-18648: Make records in FetchResponse nullable again

  #19131 merged Mar 6, 2025

• MINOR: Update log4j2 to 2.24.3

  #19135 merged Mar 6, 2025

• KAFKA-18887: Implement Streams Admin APIs

  #19120 merged Mar 6, 2025

• MINOR: transformValues test improvement

  #19106 merged Mar 6, 2025

• MINOR: Added evolving annotation to DeleteShareGroupsResult.

  #19133 merged Mar 6, 2025

• HOTFIX Disable branch protections on trunk

  #19139 merged Mar 6, 2025

• KAFKA-18811: Added command configs to admin client as well in VerifiableShareConsumer

  #19130 merged Mar 6, 2025

• MINOR: Cleanup import-control-core.xml

  #19095 merged Mar 6, 2025

• MINOR: Update upgrade steps

  #19132 merged Mar 6, 2025

• MINOR: Improve the example of kafka-metadata-shell.sh

  #19107 merged Mar 6, 2025

• KAFKA-18910 Remove kafka.utils.json

  #19112 merged Mar 6, 2025

• HOTFIX: Do not use highest version when version is valid

  #19109 merged Mar 6, 2025

• HOTFIX Fix asf.yaml strict [2/n]

  #19126 merged Mar 5, 2025

• HOTFIX Fix asf.yaml strict [1/n]

  #19124 merged Mar 5, 2025

• MINOR Add a required status check for trunk

  #19122 merged Mar 5, 2025

• MINOR: Delete DeleteGroupsResult class.

  #19057 merged Mar 5, 2025

• KAFKA-18887 Implement Streams Admin APIs

  #19049 merged Mar 5, 2025

• MINOR: Fix typos in multiple files

  #19102 merged Mar 5, 2025

• KAFKA-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde

  #19104 merged Mar 5, 2025

• KAFKA-18882 Remove BaseKey, TxnKey, and UnknownKey

  #19054 merged Mar 5, 2025

• KAFKA-18817: ShareGroupHeartbeat and ShareGroupDescribe API must check topic describe

  #19083 merged Mar 5, 2025

• KAFKA-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

  #18983 merged Mar 5, 2025

• KAFKA-18804: Remove slf4j warning when using tool script

  #18918 merged Mar 5, 2025

• MINOR: KAFKA-18876 4.0 docs follow-up

  #19103 merged Mar 5, 2025

• MINOR: Refactor GroupCoordinatorConfig

  #19092 merged Mar 5, 2025

• KAFKA-10864: Convert end txn marker schema to use auto-generated protocol

  #9766 merged Mar 5, 2025

• KAFKA-18886: add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft

  #19087 merged Mar 5, 2025

• MINOR Auto-approve Pull Request Reviewed with ci-approved label

  #19098 merged Mar 5, 2025

• MINOR: Fix grammar and clarity in zk2kraft.html

  #19096 merged Mar 4, 2025

• KAFKA-18422: add Kafka client upgrade path

  #19097 merged Mar 4, 2025

• KAFKA-18917: TransformValues throws NPE

  #19089 merged Mar 4, 2025

• KAFKA-18876: 4.0 documentation improvement

  #19065 merged Mar 4, 2025

• Fix typos in multiple files

  #19086 merged Mar 4, 2025

• KAFKA-18918: Correcting releasing of locks on exception

  #19091 merged Mar 4, 2025

• MINOR: Small refactor in GroupMetadataManager

  #19090 merged Mar 4, 2025

• KAFKA-18916; Resolved regular expressions must update the group by topics data structure

  #19088 merged Mar 4, 2025

• KAFKA-18844: Stale features information in QuorumController#registerBroker (#18997)

  #19058 merged Mar 4, 2025

• KAFKA-18867: add tests to describe topic configs with empty name

  #19075 merged Mar 4, 2025

• KAFKA-18500 Build PRs at HEAD commit

  #18449 merged Mar 4, 2025

• MINOR: Prevent broker fencing by adjusting resendExponentialBackoff in BrokerLifecycleManager

  #19061 merged Mar 3, 2025

• HOTFIX: remove PageView example to support Java11 for :streams:examples module

  #19052 merged Mar 3, 2025

• MINOR: Don't print cleaning group metadata log if empty

  #19080 merged Mar 3, 2025

• KAFKA-18878: Added share session cache and delayed share fetch metrics (KIP-1103)

  #19059 merged Mar 3, 2025

• HOTFIX: Revert "KAFKA-18067: Kafka Streams can leak Producer client under EOS (#17931)"

  #19078 merged Mar 3, 2025

• KAFKA-18817:[1/N] ShareGroupHeartbeat and ShareGroupDescribe API must check topic describe

  #19055 merged Mar 3, 2025

• MINOR: Extract HeartbeatRequestState from heartbeat request managers

  #19043 merged Mar 3, 2025

• KAFKA-18613: Auto-creation of internal topics in streams group heartbeat

  #18981 merged Mar 3, 2025

• KAFKA-18881: Document the ConsumerRecord as non-thread safe

  #19056 merged Mar 3, 2025

• KAFKA-18168: Adding checkpointing for GlobalKTable during restoration…

  #18752 merged Mar 2, 2025

• KAFKA-18907: Add suitable error message when the appended value is too larger

  #19070 merged Mar 2, 2025

• KAFKA-18908: Document that the size of appended value can't be larger than Short.MAX_VALUE

  #19067 merged Mar 2, 2025

41 Pull requests opened by 25 people

• [MINOR] Cleanup Storage Module

  #19072 opened Mar 2, 2025

• MINOR: Disable failing "Load Test Catalog" job on public forks

  #19073 opened Mar 2, 2025

• KAFKA-18607: Update jfreechart dependency

  #19074 opened Mar 2, 2025

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

  #19076 opened Mar 3, 2025

• KAFKA-13022: Optimize ClientQuotasImage#describe

  #19079 opened Mar 3, 2025

• KAFKA-18909: Move DynamicThreadPool to server module

  #19081 opened Mar 3, 2025

• KAFKA-17014: ScramFormatter should not use String for password

  #19082 opened Mar 3, 2025

• [MINOR] Cleanup Server Common Module

  #19085 opened Mar 4, 2025

• KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups

  #19093 opened Mar 4, 2025

• KAFKA-18637: Fix max connections per ip and override reconfigurations

  #19099 opened Mar 4, 2025

• KAFKA-18031: Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt

  #19105 opened Mar 5, 2025

• KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol

  #19110 opened Mar 5, 2025

• KAFKA-18923: resource leak in RSM fetchIndex inputStream

  #19111 opened Mar 5, 2025

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

  #19114 opened Mar 5, 2025

• KAFKA-18422 Adjust Kafka client upgrade path section

  #19119 opened Mar 5, 2025

• KAFKA-18736: Decide when a heartbeat should be sent

  #19121 opened Mar 5, 2025

• Testing: run build serially

  #19128 opened Mar 6, 2025

• KAFKA-18703: Remove unused class PayloadKeyType

  #19129 opened Mar 6, 2025

• KAFKA-18927: Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

  #19134 opened Mar 6, 2025

• KAFKA-18781: Extend RefreshRetriableException related exceptions

  #19136 opened Mar 6, 2025

• MINOR:correct user reference in quota configuration from 'userA' to 'user1'

  #19140 opened Mar 6, 2025

• MINOR: Improve grammar and clarity in upgrade.html

  #19141 opened Mar 6, 2025

• KAFKA-18901: [1/N] Improved homogeneous SimpleAssignor

  #19142 opened Mar 6, 2025

• KAFKA-18933 Add client integration tests module

  #19144 opened Mar 6, 2025

• KAFKA-18936: Fix share fetch when records are larger than max bytes

  #19145 opened Mar 6, 2025

• KAFKA-18924 Running the storage module tests produces a storage/storage.log file

  #19147 opened Mar 7, 2025

• KAFKA-18932: Removed usage of partition max bytes from share fetch requests on the broker

  #19148 opened Mar 7, 2025

• MINOR: fix: add missing @Test lost while rebasing

  #19149 opened Mar 7, 2025

• KAFKA-15931: Reopen TransactionIndex if channel is closed (#15241)

  #19150 opened Mar 7, 2025

• MINOR remove legacy branch protections from asf.yaml

  #19152 opened Mar 7, 2025

• MINOR KIP link change to use immutable link

  #19153 opened Mar 7, 2025

• Kafka-18914 Migrate ConsumerRebootstrapTest to use new test infra

  #19154 opened Mar 7, 2025

• KAFKA-18925: Add streams groups support to Admin.listGroups

  #19155 opened Mar 7, 2025

• KAFKA-18778 Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand

  #19157 opened Mar 7, 2025

• MINOR: Fix minor issues in ops doc

  #19158 opened Mar 7, 2025

• MINOR Improve PR linter output

  #19159 opened Mar 7, 2025

• [KAFKA-18941] Removes unneeded tests from upgrade_tests.py

  #19162 opened Mar 7, 2025

• MINOR: Use readable interface to parse requests

  #19163 opened Mar 7, 2025

• KAFKA-18943: Kafka Streams incorrectly commits TX during task revokation

  #19164 opened Mar 8, 2025

• Fix infinite loop and standardize options in MetadataSchemaCheckerTool

  #19165 opened Mar 8, 2025

• KAFKA-18944: Remove unused setters from ClusterConfig

  #19166 opened Mar 9, 2025

69 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-14484: Move UnifiedLog to storage module

  #19030 commented on Mar 8, 2025 • 45 new comments

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

  #18987 commented on Mar 5, 2025 • 23 new comments

• KAFKA-18602: Incorrect FinalizedVersionLevel reported for dynamic KRaft quorum

  #18685 commented on Mar 8, 2025 • 21 new comments

• KAFKA-18074: Add kafka client compatibility matrix

  #18091 commented on Mar 8, 2025 • 13 new comments

• KAFKA-16718-2/n: KafkaAdminClient and GroupCoordinator implementation for DeleteShareGroupOffsets RPC

  #18976 commented on Mar 6, 2025 • 13 new comments

• KAFKA-17431: Support invalid static configs for KRaft so long as dynamic configs are valid

  #18949 commented on Mar 7, 2025 • 10 new comments

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

  #18600 commented on Mar 8, 2025 • 9 new comments

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

  #19026 commented on Mar 3, 2025 • 7 new comments

• KAFKA-18142 switch Kafka's Gradle build shadow plugin to `com.gradleup.shadow` (and upgrade plugin version)

  #18018 commented on Mar 7, 2025 • 5 new comments

• MINOR: Rewrite unchecked operations in Mock API

  #19071 commented on Mar 9, 2025 • 5 new comments

• KAFKA-18332: fix ClassDataAbstractionCoupling problem in KafkaRaftClientTest(1/2)

  #18926 commented on Mar 6, 2025 • 4 new comments

• KAFKA-18843: Fix MirrorMaker2 workerId is not unique, but use the sam…

  #18994 commented on Mar 7, 2025 • 3 new comments

• KAFKA-18854:Move DynamicConfig to server module

  #19019 commented on Mar 6, 2025 • 3 new comments

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

  #17614 commented on Mar 8, 2025 • 3 new comments

• KAFKA-17565: Move MetadataCache interface to metadata module

  #18801 commented on Mar 9, 2025 • 2 new comments

• KAFKA-18195: Enter incompatible instead of leaving incompatible entires blank in Kafka Streams broker compatibility matrix

  #18258 commented on Mar 7, 2025 • 2 new comments

• KAFKA-17516: Synonyms for client metrics configs

  #17264 commented on Mar 6, 2025 • 2 new comments

• KAFKA-18572: Update Kafka Streams metric documenation

  #18673 commented on Mar 7, 2025 • 1 new comment

• MINOR: Disallow unused local variables

  #18963 commented on Mar 7, 2025 • 1 new comment

• KAFKA-18617 Allow use of ClusterInstance inside BeforeEach

  #18662 commented on Mar 6, 2025 • 1 new comment

• KAFKA-18859: honor the error message of UnregisterBrokerResponse

  #19027 commented on Mar 3, 2025 • 1 new comment

• MINOR Capture heap dump after OOM on CI

  #19031 commented on Mar 7, 2025 • 1 new comment

• KAFKA-18276 Migrate ProducerRebootstrapTest to new test infra

  #19046 commented on Mar 9, 2025 • 1 new comment

• KAFKA-18893: KIP-877 Add support for ReplicaSelector

  #19064 commented on Mar 6, 2025 • 1 new comment

• KAFKA-15900, KAFKA-18310: fix flaky test testOutdatedCoordinatorAssignment and AbstractCoordinatorTest

  #18945 commented on Mar 9, 2025 • 0 new comments

• MINOR: Clean up metadata module

  #19069 commented on Mar 8, 2025 • 0 new comments

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

  #19068 commented on Mar 6, 2025 • 0 new comments

• KAFKA-4650: Add unit tests for GraphNode class

  #18951 commented on Mar 3, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

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

• KAFKA-18834 Fix LoggingResourceTest#testSetLevelDefaultScope

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

• KAFKA-18899: Limit retry time for ShareConsumer.commitAsync

  #19060 commented on Mar 3, 2025 • 0 new comments

• Clarification of topic configuration 'retention.bytes'

  #19051 commented on Mar 7, 2025 • 0 new comments

• KAFKA-18888: Add KIP-877 support to Authorizer

  #19050 commented on Mar 3, 2025 • 0 new comments

• KAFKA-18837: Validate controller.quorum.fetch.timeout.ms is a positive value

  #18998 commented on Mar 6, 2025 • 0 new comments

• [KAFKA-18713] Left join bug integration test

  #19005 commented on Mar 4, 2025 • 0 new comments

• Nilmadhab/co grouped windowed aggrgation

  #19014 commented on Mar 3, 2025 • 0 new comments

• KAFKA-18873: Fixed incorrect error message when exceeds 5 for transactional producers

  #19041 commented on Mar 8, 2025 • 0 new comments

• KAFKA-18858: Refactor FeatureControlManager to avoid using uninitialized MV

  #19040 commented on Mar 4, 2025 • 0 new comments

• KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner.

  #19035 commented on Mar 6, 2025 • 0 new comments

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

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

• MINOR: Using rocksdb's prefixScan in fk joins for better performances

  #16218 commented on Mar 4, 2025 • 0 new comments

• KAFKA-16907: Fix RaftUtil's type complexity

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

• KAFKA-17037:KIP-919 supports for `describeClientQuotas` and `alterClientQuotas`

  #17339 commented on Mar 6, 2025 • 0 new comments

• KAFKA-17645: KIP-1052: Enable warmup in producer performance test

  #17340 commented on Mar 3, 2025 • 0 new comments

• Support keystore with multiple alias entries

  #17560 commented on Mar 4, 2025 • 0 new comments

• KAFKA-17856 Move ConfigCommandTest and ConfigCommandIntegrationTest to tool module

  #17767 commented on Mar 6, 2025 • 0 new comments

• KAFKA-18024 ConcurrentModificationException in Kafka OffsetFetcher - Proposal for Thread-Safety Fix - Update OffsetFetcher.java

  #17826 commented on Mar 7, 2025 • 0 new comments

• KAFKA-18001: Support UpdateRaftVoterRequest in KafkaNetworkChannel (#…

  #17830 commented on Mar 4, 2025 • 0 new comments

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

  #17981 commented on Mar 4, 2025 • 0 new comments

• KAFKA-10731: add support for SSL hot reload

  #17987 commented on Mar 9, 2025 • 0 new comments

• Change testing for git command in Compatibility Checker

  #18006 commented on Mar 3, 2025 • 0 new comments

• KAFKA-18166: Indefinite timeout when publishing events to RLMM (RemoteLogMetadataManager)

  #18097 commented on Mar 5, 2025 • 0 new comments

• KAFKA-10730: KafkaApis#handleProduceRequest should use auto-generated protocol

  #18216 commented on Mar 5, 2025 • 0 new comments

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

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

• KAFKA-17544: Fix for loading big files while performing load tests

  #18391 commented on Mar 5, 2025 • 0 new comments

• KAFKA-17171: Add test cases for `STATIC_BROKER_CONFIG`in kraft mode

  #18463 commented on Mar 8, 2025 • 0 new comments

• KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread

  #18489 commented on Mar 9, 2025 • 0 new comments

• [WIP] KIP-1135: Deprecated "org.apache.kafka.disallowed.login.modules"

  #18683 commented on Mar 6, 2025 • 0 new comments

• KAFKA-18576: Convert ConfigType to Enum

  #18711 commented on Mar 9, 2025 • 0 new comments

• KAFKA-16505: Fix lost source raw key and value in store caches and buffers

  #18739 commented on Mar 4, 2025 • 0 new comments

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

  #18789 commented on Mar 9, 2025 • 0 new comments

• DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation"

  #18800 commented on Mar 5, 2025 • 0 new comments

• KAFKA-18706: Move AclPublisher to metadata module

  #18802 commented on Mar 7, 2025 • 0 new comments

• KAFKA-16653: Remove delayed initialization because of static voter set

  #18885 commented on Mar 6, 2025 • 0 new comments

• KAFKA-18713: Fix left join bug by using DELETE_KEY_NO_PROPAGATE

  #18887 commented on Mar 3, 2025 • 0 new comments

• [WIP] JWT bearer grant type support

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

• MINOR: TopicIdPartition Records Benchmark

  #18917 commented on Mar 6, 2025 • 0 new comments

• KAFKA-18816: Add KIP-877 support to KafkaPrincipalBuilder

  #18935 commented on Mar 3, 2025 • 0 new comments

• MINOR: Cleanup metadata module

  #18937 commented on Mar 6, 2025 • 0 new comments