40 Pull requests merged by 24 people

• KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration

  #17210 merged Sep 18, 2024

• KAFKA-17048; Add docs for KIP-853

  #17076 merged Sep 18, 2024

• KAFKA-17559: Fix the flaky RemoteLogOffsetReader#testTaskQueueFullAndCancelTask

  #17214 merged Sep 18, 2024

• MINOR: Log pending join members

  #17219 merged Sep 18, 2024

• MINOR: Fix a race and add JMH bench for HdrHistogram

  #17184 merged Sep 17, 2024

• KAFKA-17472: Speed Up DescribeConsumerGroupTest

  #17117 merged Sep 17, 2024

• Revert "KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)"

  #17218 merged Sep 17, 2024

• MINOR: update documentation link to 3.9

  #17216 merged Sep 17, 2024

• MINOR: fix rawtype warning in StandbyTask

  #17203 merged Sep 16, 2024

• KAFKA-14482: Move LogLoader to storage module

  #17042 merged Sep 16, 2024

• KAFKA-16331: Remove EOSv1 from Kafka Streams integration tests

  #17110 merged Sep 16, 2024

• KAFKA-17322: Document required header versions in Protocol Guide

  #16867 merged Sep 16, 2024

• KAFKA-17494: Document message structure in Protocol Guide

  #17122 merged Sep 16, 2024

• KAFKA-15859: Make RemoteListOffsets call an async operation

  #16602 merged Sep 15, 2024

• MINOR: Need to split the controller bootstrap servers on ',' in list comprehenson

  #17183 merged Sep 15, 2024

• KAFKA-17066: new consumer updateFetchPositions all in background thread

  #16885 merged Sep 15, 2024

• MINOR: Log reason holding the completion of the join phase in the classic protocol

  #17197 merged Sep 15, 2024

• KAFKA-16027: Refactor MetadataTest#testUpdatePartitionLeadership

  #17083 merged Sep 15, 2024

• MINOR: Fix Javadoc URL for KafkaProducer in design.html

  #17200 merged Sep 15, 2024

• KAFKA-17513: Move LogSegmentsTest to storage module

  #17173 merged Sep 14, 2024

• MINOR Always publish build scan in CI Complete workflow

  #17195 merged Sep 14, 2024

• MINOR: Increase logging verbosity in Connect integration tests

  #17189 merged Sep 14, 2024

• KAFKA-17543: Enforce that broker.id.generation.enable is not used when migrating to KRaft

  #17192 merged Sep 14, 2024

• KAFKA-17527: Fix NPE for null RecordContext

  #17169 merged Sep 13, 2024

• MINOR: Update to 4.1.0 of setup-gradle action

  #17194 merged Sep 13, 2024

• KAFKA-16681: Rewrite MiniKDC by Java

  #16213 merged Sep 13, 2024

• KAFKA-17036: KIP-919 supports for createAcls, deleteAcls, describeAcls

  #16493 merged Sep 13, 2024

• KAFKA-16468: verify that migrating brokers provide their inter.broker.listener

  #17159 merged Sep 13, 2024

• MINOR Add a thread dump on build timeout

  #17181 merged Sep 13, 2024

• KAFKA-17508: Adding some guard for fallback deletion logic

  #17154 merged Sep 13, 2024

• KAFKA-17502: Modified commitSync() and close() handling in clients

  #17136 merged Sep 13, 2024

• MINOR: Update version.py

  #17186 merged Sep 13, 2024

• KAFKA-12601: Remove deprecated delegation.token.master.key

  #17082 merged Sep 13, 2024

• KAFKA-17489: Do not handle failed tasks as tasks to assign

  #17115 merged Sep 13, 2024

• KAFKA-17524: Add timeout to StreamThreadTest

  #17180 merged Sep 12, 2024

• Refactored share module classes and minor fix

  #17178 merged Sep 12, 2024

• KAFKA-17427: Deprecate leaking *_DOC variables in StreamsConfig

  #17171 merged Sep 12, 2024

• KAFKA-17253: Deprecate Leaking Getter Methods in Joined Helper Class

  #17164 merged Sep 12, 2024

• MINOR: Bump zstd-jni from 1.5.6-4 to 1.5.6-5

  #17151 merged Sep 12, 2024

• KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer

  #17172 merged Sep 12, 2024

38 Pull requests opened by 21 people

• KAFKA-17512: Move LogSegmentTest to storage module

  #17174 opened Sep 12, 2024

• KAFKA-17532: Moved ShareGroupConfig to share module

  #17176 opened Sep 12, 2024

• KAFKA-17509: Introduce a delayed action queue to complete purgatory actions outside purgatory.

  #17177 opened Sep 12, 2024

• KAFKA-17528: Remove whitelist/blacklist from JMXReporter

  #17179 opened Sep 12, 2024

• KAFKA-17488: Cleanup (test) code for Kafka Streams "metric version"

  #17182 opened Sep 12, 2024

• MINOR: improve RecordCollectorImpl

  #17185 opened Sep 13, 2024

• KAFKA-17515: Fix flaky RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener

  #17187 opened Sep 13, 2024

• KAFKA-17546: Admin.listGroups and kafka-groups.sh

  #17188 opened Sep 13, 2024

• KAFKA-12829: Remove deprecated Topology#addProcessor of old Processor…

  #17190 opened Sep 13, 2024

• KAFKA-17553 Fix shutdown race condition in StreamThreadTest

  #17191 opened Sep 13, 2024

• KAFKA-17076: retain last batch in each round of cleaning

  #17193 opened Sep 13, 2024

• MINOR: Fix DefaultRecordBatch protocol documentation.

  #17196 opened Sep 14, 2024

• KAFKA-16339: [1/4 KStream#transform] Remove Deprecated "transformer" methods and classes

  #17198 opened Sep 15, 2024

• KAFKA-16143: New JMX metrics for AsyncKafkaConsumer

  #17199 opened Sep 15, 2024

• KAFKA-17526: make ConfigCommandIntegrationTest.java test use correct arguments in testing alias

  #17201 opened Sep 15, 2024

• KAFKA-17529: Remove blacklist from MM2

  #17202 opened Sep 15, 2024

• KAFKA-17540: Create floating tag on trunk for CI cache

  #17204 opened Sep 16, 2024

• MINOR: Fix SubscriptionResponseWrapperSerializer

  #17205 opened Sep 16, 2024

• MINOR: fix generics in streams-test-utils package

  #17206 opened Sep 16, 2024

• MINOR: fixing JavaDocs and other cleanup

  #17207 opened Sep 16, 2024

• KAFKA-17542: Use actions/labeler for automatic PR labeling

  #17208 opened Sep 16, 2024

• KAFKA-17109: Move lock backoff retry to streams TaskManager

  #17209 opened Sep 16, 2024

• KAFKA-17356 add IT for KAFKA-17310

  #17211 opened Sep 16, 2024

• Kafka 16331 eosv1 streamsproducer

  #17212 opened Sep 16, 2024

• KAFKA-6197: Update Streams API and Javadoc references in documentation

  #17215 opened Sep 17, 2024

• KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest

  #17217 opened Sep 17, 2024

• KAFKA-17555: uncomment all checks of testCommonNameLoggingTrustManagerMixValidAndInvalidCertificates

  #17220 opened Sep 18, 2024

• MINOR: Fix a race and add JMH bench for HdrHistogram

  #17221 opened Sep 18, 2024

• KAFKA-17087: Deprecate `delete-config` of TopicCommand

  #17222 opened Sep 18, 2024

• KAFKA-17563: Move `RequestConvertToJson` to server module

  #17223 opened Sep 18, 2024

• KAFKA-17385: Remove authorizer, authorizer-properties, zk-tls-config-file in AclCommand

  #17224 opened Sep 18, 2024

• KAFKA-17574: Allow overriding TestKitNodes baseDirectory

  #17225 opened Sep 18, 2024

• KAFKA-17575: Remove unnecessary file.deleteOnExit call

  #17226 opened Sep 18, 2024

• MINOR Fix is-public-fork input type

  #17227 opened Sep 18, 2024

• KAFKA-17564: Move BrokerFeatures to server module

  #17228 opened Sep 18, 2024

• MINOR Group the junit parser console logs

  #17229 opened Sep 18, 2024

• KAFKA-17505: New consumer seekToBeginning/End should run in background thread

  #17230 opened Sep 19, 2024

• KAFKA-16908: Refactor `QuorumConfig` with `AbstractConfig`

  #17231 opened Sep 19, 2024

58 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-17367: Share coordinator impl. Added additional tests. [3/N]

  #17149 commented on Sep 18, 2024 • 37 new comments

• KAFKA-17154: New consumer subscribe may join group without a call to consumer.poll

  #17165 commented on Sep 18, 2024 • 13 new comments

• KAFKA-17439: Make polling for new records an explicit action/event in the new consumer

  #17035 commented on Sep 13, 2024 • 10 new comments

• KAFKA-10551: Add topic id support to produce request and response

  #15968 commented on Sep 12, 2024 • 9 new comments

• KAFKA-17248 - KIP 1076 implementation

  #17021 commented on Sep 13, 2024 • 8 new comments

• KAFKA-16331: remove EOSv1 config from StreamsConfig

  #17170 commented on Sep 18, 2024 • 7 new comments

• KAFKA-12827 Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler

  #16988 commented on Sep 16, 2024 • 7 new comments

• KAFKA-17525: Convert the UnknownServerException to InvalidRequestException when altering client-metrics config at runtime

  #17168 commented on Sep 14, 2024 • 6 new comments

• KAFKA-17285: Consider using `Utils.closeQuietly` to replace `CoreUtils.swallow` when handling Closeable objects

  #16843 commented on Sep 16, 2024 • 6 new comments

• KAFKA-12823 Remove Deprecated method KStream#through (KIP-1087)

  #16761 commented on Sep 18, 2024 • 5 new comments

• KAFKA-16308 [3/N]: Introduce feature dependency validation to UpdateFeatures command

  #16443 commented on Sep 16, 2024 • 5 new comments

• KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0)

  #16982 commented on Sep 19, 2024 • 5 new comments

• KAFKA-15344: Streams task should cache consumer nextOffsets

  #17091 commented on Sep 13, 2024 • 5 new comments

• KAFKA-17465: Make getMembersFromGroup be non-blocking

  #17080 commented on Sep 17, 2024 • 4 new comments

• KAFKA-17374: add bootstrap.controller to kafka-reassign-partitions.sh

  #16964 commented on Sep 16, 2024 • 3 new comments

• KAFKA-16985: Ensure consumer sends leave request on close even if interrupted

  #16686 commented on Sep 16, 2024 • 2 new comments

• KAFKA-17415: Avoid overflow of expired timestamp

  #17026 commented on Sep 16, 2024 • 2 new comments

• KAFKA-17277: [2/2] Add feature dependency command to the storage and the feature command tool

  #17093 commented on Sep 13, 2024 • 2 new comments

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

  #17139 commented on Sep 13, 2024 • 2 new comments

• KAFKA-17057: Add RETRY option to ProductionExceptionHanlder

  #17163 commented on Sep 14, 2024 • 2 new comments

• MINOR: add ReconfigurableQuorumIntegrationTest

  #16991 commented on Sep 13, 2024 • 1 new comment

• KAFKA-15859: Add timeout field to the ListOffsets request

  #17112 commented on Sep 16, 2024 • 1 new comment

• KAFKA-16564: Apply `Xlint` to java code in core module

  #16965 commented on Sep 17, 2024 • 1 new comment

• KAFKA-16963 followup: Ducktape test for KIP-853

  #17146 commented on Sep 15, 2024 • 1 new comment

• KAFKA-16813: Add global timeout for "@Test" and "@TestTemplate" (For Github Action)

  #16957 commented on Sep 18, 2024 • 1 new comment

• KAFKA-17480: New consumer commit all consumed should retrieve offsets in background thread

  #17150 commented on Sep 18, 2024 • 1 new comment

• KAFKA-17338 ConsumerConfig should prevent using partition assignors with CONSUMER group protocol

  #16899 commented on Sep 17, 2024 • 1 new comment

• KAFKA-5359: Use a suppressed exception when throwing`RequestFuture.exception()`

  #3213 commented on Sep 14, 2024 • 0 new comments

• KAFKA-5326:When resize the index file, maybe cause the content disappear

  #3143 commented on Sep 14, 2024 • 0 new comments

• KAFKA-5237 - change logging of termination message to use stderr instead of stdout

  #3052 commented on Sep 14, 2024 • 0 new comments

• KAFKA-17337: ConsumerConfig should default to CONSUMER for group.protocol

  #17107 commented on Sep 13, 2024 • 0 new comments

• MINOR: Fix some lgtm.com alerts, ensuring certain input/output resources are closed.

  #2939 commented on Sep 14, 2024 • 0 new comments

• KAFKA-17498: Reduce the number of remote calls when serving LIST_OFFSETS request

  #17132 commented on Sep 16, 2024 • 0 new comments

• New transform: ExtractFields

  #2880 commented on Sep 13, 2024 • 0 new comments

• KAFKA-4808 : Send of null key to a compacted topic should throw non-retriable error back to user

  #2875 commented on Sep 13, 2024 • 0 new comments

• KAFKA-5072[WIP]: Kafka topics should allow custom metadata configs within some config namespace

  #2873 commented on Sep 17, 2024 • 0 new comments

• KAFKA-5050 add ldap authentication support on PlainSaslServer

  #2833 commented on Sep 13, 2024 • 0 new comments

• KAFKA-14577: Move ConsoleProducer to tools module

  #17157 commented on Sep 15, 2024 • 0 new comments

• the kafka-server-stop.sh can not find the pids.

  #2790 commented on Sep 13, 2024 • 0 new comments

• KAFKA-2961: Add overload for subscribing to a single partition

  #2785 commented on Sep 13, 2024 • 0 new comments

• KAFKA-17524: Add timeout to StreamThreadTest.shouldReturnErrorIfProducerInstanceIdNotInitialized

  #17167 commented on Sep 12, 2024 • 0 new comments

• KAFKA-4858: Broker should ignore long topic names

  #2673 commented on Sep 13, 2024 • 0 new comments

• Kafka 960 metrics upgrade

  #2312 commented on Sep 13, 2024 • 0 new comments

• KAFKA-17421: Add IT for ConsumerRecord#leaderEpoch

  #17063 commented on Sep 13, 2024 • 0 new comments

• KAFKA-17233: MirrorCheckpointConnector should use batched listConsumerGroupOffsets

  #17038 commented on Sep 17, 2024 • 0 new comments

• Fixed path to log4j config file

  #3260 commented on Sep 15, 2024 • 0 new comments

• Fixed file URI path to log4j in bin/windows batch files

  #3270 commented on Sep 15, 2024 • 0 new comments

• KAFKA-3199 LoginManager should allow using an existing Subject

  #3274 commented on Sep 16, 2024 • 0 new comments

• KAFKA-17287: Added integration tests for ShareConsumer

  #17009 commented on Sep 12, 2024 • 0 new comments

• MINOR: Update TopologyTest

  #17006 commented on Sep 16, 2024 • 0 new comments

• KAFKA-9278: Remove static exception instance

  #7788 commented on Sep 12, 2024 • 0 new comments

• KAFKA-16710:Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception

  #15929 commented on Sep 12, 2024 • 0 new comments

• KAFKA-15045: (KIP-924) Extend TaskAssignorIntegrationTest with new public TaskAssignor

  #16349 commented on Sep 12, 2024 • 0 new comments

• [Don't Merge] Test

  #16463 commented on Sep 17, 2024 • 0 new comments

• Kafka-16355: Fix ConcurrentModificationException in evictWhile Method

  #16554 commented on Sep 12, 2024 • 0 new comments

• KAFKA-16437 - Upgrade to Jakarta and Jetty 12 (KIP-1032)

  #16754 commented on Sep 18, 2024 • 0 new comments

• KAFKA-17053: Restructure build.gradle to configure publishing last

  #16950 commented on Sep 18, 2024 • 0 new comments

• KAFKA-16683: Extract security-related helpers from scala.TestUtils to java class

  #16912 commented on Sep 17, 2024 • 0 new comments