43 Pull requests merged by 20 people

• KAFKA-16765: NioEchoServer leaks accepted SocketChannel instances due to race condition

  #16576 merged Jul 24, 2024

• KAFKA-16666: Migrate TransactionLogMessageFormatter to tools module

  #16019 merged Jul 24, 2024

• KAFKA-17021: Migrate AclCommandTest to new test infra

  #16500 merged Jul 24, 2024

• MINOR: Update collaborators list

  #16679 merged Jul 24, 2024

• MINOR: add comment for correctness issue to LeaderEpochFileCache

  #16660 merged Jul 24, 2024

• MINOR: Replace lambda expressions with method references for ReplicationControlManager

  #16547 merged Jul 24, 2024

• KAFKA-17160: Determine mockitoArtifactName based on mockitoVersion instead of JavaVersion

  #16639 merged Jul 24, 2024

• KAFKA-17179: Remove integration tag in class level when using ClusterTestExtensions

  #16656 merged Jul 24, 2024

• KAFKA-17104: fix InvalidMessageCrcRecordsPerSec is not updated in validating Legac…

  #16558 merged Jul 24, 2024

• KAFKA-17168: Remove the logPrefix to print the thread name

  #16657 merged Jul 24, 2024

• KAFKA-17163:revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure

  #16638 merged Jul 24, 2024

• KAFKA-16584 Make log processing summary configurable or debug

  #16509 merged Jul 23, 2024

• MINOR: Clarify ACL requirements for Connect workers when exactly.once.source.support is set to preparing

  #16636 merged Jul 23, 2024

• KAFKA-16068: Use TestPlugins mechanism in ConnectorValidationIntegrationTest to prevent ERROR-level log spam in unrelated test suites

  #16647 merged Jul 23, 2024

• MINOR: Extract SockerServer inner classes to server module

  #16632 merged Jul 23, 2024

• KAFKA-17149: Move ProducerStateManagerTest to storage module

  #16645 merged Jul 23, 2024

• KAFKA-16791: Add thread detection to ClusterTestExtensions

  #16499 merged Jul 23, 2024

• KAFKA-17159: Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit

  #16633 merged Jul 22, 2024

• MINOR: Move queued.max.requests, queued.max.request.bytes to SocketSe…

  #16634 merged Jul 22, 2024

• KAFKA-17166: Use NoOpScheduler to rewrite LogManagerTest#testLogRecoveryMetrics

  #16641 merged Jul 22, 2024

• MINOR: Various cleanups in metadata

  #16610 merged Jul 22, 2024

• KAFKA-17168 The logPrefix of RemoteLogReader/RemoteStorageThreadPool is not propagated correctly

  #16642 merged Jul 21, 2024

• KAFKA-17082: replace kafka.utils.LogCaptureAppender with org.apache.kafka.common.utils.LogCaptureAppender

  #16601 merged Jul 21, 2024

• KAFKA-17153 KafkaMetricsGroup#newGauge should accept functional interface instead of com.yammer.metrics.core.Gague

  #16618 merged Jul 21, 2024

• KAFKA-17144: Retract unimplemented ListGroups v6 added in error

  #16635 merged Jul 21, 2024

• KAFKA-17152: Make sure zk session tracker gets down when closing embedded zk.

  #16609 merged Jul 21, 2024

• KAFKA-17172: Add @Tag("integration") to ClusterTest, ClusterTemplate and ClusterTests

  #16640 merged Jul 21, 2024

• MINOR: Add integration test for plugin aliases

  #16621 merged Jul 19, 2024

• KAFKA-17132: Revisit testMissingOffsetNoResetPolicy for AsyncConsumer

  #16587 merged Jul 19, 2024

• KAFKA-17121: junit-platform.properties files in published artifacts pollute the test classpath of consumers

  #16624 merged Jul 19, 2024

• KAFKA-16448: Catch and handle processing exceptions

  #16093 merged Jul 19, 2024

• KAFKA-16984: Complete consumer leave on response to leave request

  #16569 merged Jul 19, 2024

• KAFKA-17095: Fix the typo from "CreateableTopicConfig" to "CreatableTopicConfig"

  #16623 merged Jul 19, 2024

• KAFKA-17077: The node.id is inconsistent to broker.id when "broker.id.generation.enable=true".

  #16540 merged Jul 19, 2024

• KAFKA-17122 Change the type of clusterId from UUID to String

  #16590 merged Jul 19, 2024

• KAFKA-17118: Remove StorageTool#buildMetadataProperties

  #16622 merged Jul 19, 2024

• MINOR: Improve ProducerIdExpirationTest

  #16619 merged Jul 18, 2024

• KAFKA-16975 The error message of creating __cluster_metadata should NOT be "Authorization failed"

  #16372 merged Jul 18, 2024

• MINOR: Various cleanups in raft

  #16611 merged Jul 18, 2024

• KAFKA-17142: Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics

  #16614 merged Jul 18, 2024

• KAFKA-15773: Group protocol configuration should be validated

  #16543 merged Jul 18, 2024

• KAFKA-17135 Add unit test for ProducerStateManager#readSnapshot and ProducerStateManager#writeSnapshot

  #16603 merged Jul 18, 2024

• KAFKA-17141: "DescribeTopicPartitions API is not supported" warning message confuses users

  #16612 merged Jul 18, 2024

44 Pull requests opened by 30 people

• KAFKA-17112: Manually stop task manager if stream thread is not in CREATED state

  #16625 opened Jul 18, 2024

• MINOR: Verify topic deletion for new test infra

  #16627 opened Jul 18, 2024

• KAFKA-16056: Revoking connectors and tasks upon worker poll timeout expiry to prevent duplicate task assignments

  #16628 opened Jul 18, 2024

• KAFKA-14648 - Do not fail clients if bootstrap servers is not immediately resolvable

  #16629 opened Jul 18, 2024

• [WIP] MINOR: CI testing for v3.5.3

  #16630 opened Jul 19, 2024

• KAFKA-4243: Ensure metric names are quoted as necessary for JMX

  #16631 opened Jul 19, 2024

• KAFKA-16953; Properly implement the sending of DescribeQuorumResponse

  #16637 opened Jul 19, 2024

• MINOR: Add comments to ReplicationQuotaManager

  #16643 opened Jul 21, 2024

• KAFKA-17038 KIP-919 supports for `alterPartitionReassignments` and `listPartitionReassignments`

  #16644 opened Jul 21, 2024

• KAFKA-16900 kafka-producer-perf-test reports error when using transaction.

  #16646 opened Jul 21, 2024

• KAFKA-17137: Feat admin client it acl configs

  #16648 opened Jul 22, 2024

• KAFKA-17116: New consumer may not send effective leave group if member ID received after close

  #16649 opened Jul 22, 2024

• MINOR: docs(config providers): adds a description of configuration providers

  #16650 opened Jul 22, 2024

• KAFKA-5113 : Remove handling of Errors.INVALID_FETCH_SIZE and InvalidFetchSizeException in GroupMetadataManager as they are never generated

  #16651 opened Jul 22, 2024

• KAFKA-17137: Add integration tests for admin client (Transaction and UserScramCredentials related).

  #16652 opened Jul 22, 2024

• KAFKA-16855: remote log disable policy in KRaft

  #16653 opened Jul 22, 2024

• MINOR: Fix title in upgrade header

  #16654 opened Jul 22, 2024

• MINOR: docs(bootstrap.servers): updates the property description

  #16655 opened Jul 22, 2024

• KAFKA-17137:Ensure Admin APIs are properly tested

  #16658 opened Jul 23, 2024

• KAFKA-17169: Add an EndpointsTest suite that test all of the public methods

  #16659 opened Jul 23, 2024

• KAFKA-17151: Remove waitForCondition when detecting thread leak

  #16661 opened Jul 23, 2024

• KAFKA-16448: Fix processing exception handler

  #16663 opened Jul 23, 2024

• KAFKA-16373: KIP-1028: Addressing Docker Official Images PR Comments for JVM, Native and Docker Official Images

  #16664 opened Jul 23, 2024

• KAFKA-15853: Move TransactionLogConfig and TransactionStateManagerConfig getters out of KafkaConfig

  #16665 opened Jul 23, 2024

• KAFKA-17175: Remove interface `BrokerNode` and `ControllerNode`

  #16666 opened Jul 23, 2024

• KAFKA-16915: LeaderChangeMessage supports VoterDirectoryId

  #16668 opened Jul 23, 2024

• KAFKA-16518: Implement KIP-853 flags for storage-tool.sh (WIP)

  #16669 opened Jul 23, 2024

• KAKFA-16537; Implement remove voter RPC

  #16670 opened Jul 24, 2024

• KAFKA-17176 Move FileLock to server-common module

  #16671 opened Jul 24, 2024

• KAFKA-17190: AssignmentsManager gets stuck retrying on deleted topics

  #16672 opened Jul 24, 2024

• KAFKA-17064: New consumer assign should update assignment in background thread

  #16673 opened Jul 24, 2024

• KAFKA-17177: reviewers.py should grep "authors" to offer more candidates of reviewers information

  #16674 opened Jul 24, 2024

• KAFKA-16448: Handle fatal user exception during processing error

  #16675 opened Jul 24, 2024

• KAFKA-17137: Ensure Admin APIs are properly tested (part 0)

  #16676 opened Jul 24, 2024

• KAFKA-17192 Fix MirrorMaker2 worker config does not pass config.provi…

  #16678 opened Jul 24, 2024

• KAFKA-17185: Declare all Loggers as static to prevent multiple logger instances

  #16680 opened Jul 24, 2024

• KAFKA-17062 avoid deleting segments early when copy operation is failing

  #16681 opened Jul 24, 2024

• KAFKA-17194: Don't create cluster for MetadataQuorumCommandTest#testCommandConfig

  #16682 opened Jul 24, 2024

• KAFKA-17060: Rename LegacyKafkaConsumer to ClassicKafkaConsumer

  #16683 opened Jul 24, 2024

• KAFKA-16448: Fix raw record not being cached in store

  #16684 opened Jul 24, 2024

• KIP-1068: New metrics for the new KafkaConsumer

  #16685 opened Jul 24, 2024

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

  #16686 opened Jul 24, 2024

• KAFKA-17137: feat(PlaintextAdminIntegrationTest): add test for createPartition wit…

  #16687 opened Jul 25, 2024

• KAFKA-17195: transaction-coordinator:test failing with junit error

  #16688 opened Jul 25, 2024

37 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-14569: Migrate Connect's integration test EmbeddedKafkaCluster from ZK to KRaft mode

  #16599 commented on Jul 24, 2024 • 25 new comments

• KAFKA-16192: Introduce transaction.version and usage of flexible records to coordinators

  #16183 commented on Jul 24, 2024 • 24 new comments

• KAFKA-16448: Handle processing exceptions in punctuate

  #16300 commented on Jul 24, 2024 • 20 new comments

• KAFKA-16682: Rewrite JaasTestUtils by Java

  #16579 commented on Jul 24, 2024 • 14 new comments

• KAFKA-16448: Add ErrorHandlerContext in deserialization exception handler

  #16432 commented on Jul 24, 2024 • 13 new comments

• KAFKA-16448: Add ErrorHandlerContext in production exception handler

  #16433 commented on Jul 24, 2024 • 13 new comments

• KAFKA-15999: Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder

  #16200 commented on Jul 24, 2024 • 11 new comments

• KAFKA-15561: Client support for new SubscriptionPattern based subscription

  #15188 commented on Jul 23, 2024 • 10 new comments

• KAFKA-16972: Move BrokerTopicMetrics to org.apache.kafka.storage.log.metrics

  #16387 commented on Jul 25, 2024 • 8 new comments

• KAFKA-17056 Convert producer state metadata schemas to use generated protocol

  #16592 commented on Jul 22, 2024 • 6 new comments

• KAFKA-16855 : Based on tiered state of topic, check for tasks

  #16615 commented on Jul 23, 2024 • 5 new comments

• MINOR:Topic command integration test migrate to new test infra

  #16127 commented on Jul 18, 2024 • 4 new comments

• KAFKA-16558: Implemented HeartbeatRequestState toStringBase() and added a test for it

  #16373 commented on Jul 24, 2024 • 3 new comments

• KAFKA-16689: Move LogValidatorTest to storage module

  #16167 commented on Jul 24, 2024 • 2 new comments

• MINOR: Fix flakiness in state updater unit tests

  #16562 commented on Jul 23, 2024 • 2 new comments

• Minor: Consumer group response should set error msg

  #16497 commented on Jul 24, 2024 • 1 new comment

• KAFKA-15556: Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

  #15020 commented on Jul 23, 2024 • 1 new comment

• KAFKA-16899 MembershipManagerImpl: rebalanceTimeoutMs variable name changed to commitTimeoutDuringReconciliation

  #16334 commented on Jul 24, 2024 • 1 new comment

• KAFKA-16057 : Change the configuration for adminclient connections.max.idle.ms to 9 minutes

  #16548 commented on Jul 22, 2024 • 0 new comments

• KAFKA-17091: Add @FunctionalInterface to Streams interfaces

  #16544 commented on Jul 18, 2024 • 0 new comments

• KAFKA-17115: Send LeaveGroup request if consumer receives JoinGroup response with member ID after being closed

  #16567 commented on Jul 23, 2024 • 0 new comments

• KAFKA-17108: Earliest pending upload offset

  #16584 commented on Jul 23, 2024 • 0 new comments

• KAFKA-15859: Make RemoteListOffsets call an async operation

  #16602 commented on Jul 23, 2024 • 0 new comments

• Use Classgraph since org.reflections is no longer under maintainence

  #16604 commented on Jul 24, 2024 • 0 new comments

• KAFKA-15746: KRaft support in ControllerMutationQuotaTest

  #16620 commented on Jul 21, 2024 • 0 new comments

• KAFKA-16211 Inconsistent config values in CreateTopicsResult and DescribeConfigsResult

  #16528 commented on Jul 19, 2024 • 0 new comments

• KAFKA-14460: Skip removed entries from in-memory KeyValueIterator

  #16505 commented on Jul 21, 2024 • 0 new comments

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

  #16493 commented on Jul 21, 2024 • 0 new comments

• KAFKA-16681: Rewrite MiniKDC by Java

  #16213 commented on Jul 22, 2024 • 0 new comments

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

  #15968 commented on Jul 24, 2024 • 0 new comments

• KAFKA-16810: Add flag to read from specific partitions while checking consumer performance

  #15905 commented on Jul 24, 2024 • 0 new comments

• KAFKA-15615: Improve handling of fetching during metadata updates

  #15647 commented on Jul 23, 2024 • 0 new comments

• Add s390x support to CI

  #15644 commented on Jul 18, 2024 • 0 new comments

• KAFKA-15867: Should ConsumerNetworkThread wrap the exception and notify the polling thread?

  #15312 commented on Jul 23, 2024 • 0 new comments

• KAFKA-15845: Detect leaked Kafka clients and servers with LeakTestingExtension

  #14783 commented on Jul 24, 2024 • 0 new comments

• IGNORE: Test PR for KAFKA-15062

  #14717 commented on Jul 23, 2024 • 0 new comments

• KAFKA-15062: Adding ppc64le build stage

  #13817 commented on Jul 24, 2024 • 0 new comments