Messages by Thread
-
-
[jira] [Resolved] (KAFKA-21028) Remove hamcrest from org.apache.kafka.streams.processor.internals package
majialong (Jira)
-
[PR] KAFKA-20923: Make HeaderVersions Mandatory [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20728) Post-Quantum Cryptography (PQC) TLS Readiness: Add setNamedGroups() and ssl.named.groups configuration (ref: CAMEL-23154)
Arnab Nandy (Jira)
-
[jira] [Comment Edited] (KAFKA-19028) AlterConfigPolicy with OpType.DELETE : inconsistent behavior between TOPIC and BROKER resource
Arnab Nandy (Jira)
-
[jira] [Resolved] (KAFKA-21114) Remove unused hamcrest dependencies and configuration
Ken Huang (Jira)
-
[PR] MINOR: Moving to atomic update of share sessions on initial epoch [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21127) KIP-1378: Consumer Group Renaming in MirrorMaker2
Edoardo Comar (Jira)
-
[PR] KIP-1378: Consumer Group Renaming in MirrorMaker2 [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-21126) Version updates for build and project dependencies; `gradle-versions-plugin` reference has been moved
Jira
-
[jira] [Assigned] (KAFKA-17734) KafkaConsumer.close(0) can block indefinitely in ConsumerNetworkClient.poll
Doyeon Kim (Jira)
-
[jira] [Created] (KAFKA-21126) Version updates for build and project dependencies
Jira
-
[jira] [Resolved] (KAFKA-21105) Bump Jackson version to 2.22.2
Tamas Barnabas Egyed (Jira)
-
[PR] KAFKA-21124: Prevent stale remote log size and metadata metrics after leader-to-follower transitions [kafka]
via GitHub
-
Re: [PR] KAFKA-19878 : Connect | Fixed order of arguments in assertEquals in connect package [kafka]
via GitHub
-
Re: [PR] KAFKA-18874: Fix KRaft controller registration retry on timeout [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20684) Add Deprecated anno for ConsumerRebalanceListener class/methods
Aditya Kousik (Jira)
-
[jira] [Updated] (KAFKA-20995) KIP-1371: Condition-Driven Consumer Request Manager Scheduling
Eric Chang (Jira)
-
[jira] [Assigned] (KAFKA-21125) Ensure the remote metrics get removed on leadership change
Jiayao Sun (Jira)
-
[jira] [Assigned] (KAFKA-21124) RemoteLogSizeComputationTime, RemoteLogMetadataCount, and RemoteLogSizeBytes could linger after leadership changes
Jiayao Sun (Jira)
-
[jira] [Commented] (KAFKA-21125) Ensure the remote metrics get removed on leadership change
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-21124) RemoteLogSizeComputationTime, RemoteLogMetadataCount, and RemoteLogSizeBytes could linger after leadership changes
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21125) Ensure the remote metrics get removed on leadership change
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21124) RemoteLogSizeComputationTime, RemoteLogMetadataCount, and RemoteLogSizeBytes could linger after leadership changes
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-21121: Fix offset map typo and migrate to Map.of in TaskMetadataImplTest [kafka]
via GitHub
-
[PR] KAFKA-21123: bump zstd-jni [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21123) Update zstd-jni to 1.5.7-17
Jira
-
[jira] [Updated] (KAFKA-21122) ByteBuffer serialize method for Serializer
Aditya Kousik (Jira)
-
[jira] [Created] (KAFKA-21122) ByteBuffer serialize method to the producer Serializer
Aditya Kousik (Jira)
-
[jira] [Created] (KAFKA-21121) shouldBeEqualsIfOnlyDifferInCommittedOffsets and shouldBeEqualsIfOnlyDifferInEndOffsets don't test what they want
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-21121) shouldBeEqualsIfOnlyDifferInCommittedOffsets and shouldBeEqualsIfOnlyDifferInEndOffsets don't test what they want
Hung-Yau Su (Jira)
-
Re: [PR] KAFKA-12759: Rebalance when a static member's subscription changes (classic protocol) [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21114) Remove unused hamcrest dependencies and configuration
majialong (Jira)
-
[jira] [Updated] (KAFKA-21120) Clients Connect module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[jira] [Created] (KAFKA-21120) CLONE - Connect module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[jira] [Created] (KAFKA-21119) CLONE - Connect module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[jira] [Updated] (KAFKA-21119) Generator, Tools, test-common module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[jira] [Assigned] (KAFKA-21118) Connect module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[PR] MINOR: Fold the Streams bootstrap resolution guard into the generic client config check [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21118) Connect module: replace temp file handler with JUnit 5 Temporary Directory Support
Khyati V (Jira)
-
[jira] [Created] (KAFKA-21117) Soften validation for consumer group creation
Izzy Harker (Jira)
-
[jira] [Resolved] (KAFKA-21098) RemoteDeleteLagSegments/RemoteDeleteLagBytes report a phantom lag that never drains after a leader→follower transition
Kamal Chandraprakash (Jira)
-
[jira] [Created] (KAFKA-21116) Validate configuration value size using UTF-8 bytes
Doyeon Kim (Jira)
-
Re: [PR] KAFKA-20866: Remove incremental-only append result state [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21109) Migrate RemoteLeaderEndPoint to storage module
Ziyun Fu (Jira)
-
[jira] [Assigned] (KAFKA-19388) Move EdgeCaseRequestTest to clients-integration-tests module
Ziyun Fu (Jira)
-
[PR] MINOR: Support toArray in TopicIds [kafka]
via GitHub
-
[PR] KAFKA-21106: Resolve merging of batches in ShareFetch [kafka]
via GitHub
-
[PR] KAFKA-21114: Remove unused hamcrest dependencies and configuration [kafka]
via GitHub
-
[PR] MINOR: Expand test coverage for windowed changelog restore optimization [kafka]
via GitHub
-
[PR] KAFKA-21116: Validate configuration value size using UTF-8 bytes [kafka]
via GitHub
-
[PR] KAFKA-21115: Bump slf4j to 2.0.19 and migrate log4j-slf4j-impl to log4j-slf4j2-impl [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21115) Replace logging with Slf4j 1.7.36 due to EOL
Tamas Barnabas Egyed (Jira)
-
[PR] MINOR: Make armIfNotActive epoch-aware like armOrExtend [kafka]
via GitHub
-
[PR] MINOR: Parametrize JoinGroup/Heartbeat broker tests with the topology description plugin enabled [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-21059) Consolidate maximumTimeToWait tests for Share and Consumer
Lianet Magrans (Jira)
-
[jira] [Commented] (KAFKA-21111) Ensure refiner backward compatibility
Lucas Brutschy (Jira)
-
[PR] KAFKA-20892: SimpleHeaderConverter should not infer a number from a string with trailing tokens [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20892) SimpleHeaderConverter infers a string header as a number if it starts with a digit
Pranav Siby (Jira)
-
Re: [PR] KAFKA-20774: Fix ScramDelta.apply() dropping SCRAM users [kafka]
via GitHub
-
[PR] KAFKA-21113: Apply response.http.headers.config to the Connect admin listener [kafka]
via GitHub
-
[PR] MINOR: Fix typos in KafkaConfigBackingStore and SslTransportLayer [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21113) Connect admin listener does not apply response.http.headers.config
Ashwin Pankaj (Jira)
-
[jira] [Created] (KAFKA-21113) Connect admin listener does not apply response.http.headers.config
Ashwin Pankaj (Jira)
-
[PR] KAFKA-21108: Speed up StreamsUpgradeTestIntegrationTest by explicitly leaving group on close [kafka]
via GitHub
-
[PR] MINOR: Replace ServerSideAssignorBenchmark with ConsumerAssignorBenchmark [kafka]
via GitHub
-
[PR] MINOR: Avoid ModuleNotFoundError when building without running docker tests [kafka]
via GitHub
-
[PR] KAFKA-21092: Remove channel builders from the reconfigurable list when processors close [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21112) Consider adding a assignment verification step for "streams" groups
Matthias J. Sax (Jira)
-
[PR] KAFKA-20665: re-use hot standby task for temporary active task grant [kafka]
via GitHub
-
Re: [PR] Mm2 fault tolerance enhancement [kafka]
via GitHub
-
[PR] KAFKA-16546: Add javadoc for updating cluster-wide default broker configs [kafka]
via GitHub
-
[PR] MINOR: Document 4.4+ broker requirement for static membership with the streams protocol [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21111) Ensure refiner backward compatibility
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-21111) Ensure refiner backward compatibility
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-21111) Ensure refiner backward compatibility
Matthias J. Sax (Jira)
-
[PR] KAFKA-12188: Assert specific connection failure in SaslAuthenticatorTest [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-21110) Document that min.insync.replicas is bounded by the replica count
Lucy Liu (Jira)
-
Re: [PR] KAFKA-20607: Include docs in version consistency checks and updates [kafka]
via GitHub
-
[jira] [Created] (KAFKA-21110) Document that min.insync.replicas is bounded by the replica count
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21109) Migrate RemoteLeaderEndPoint to storage module
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-20665: extend refiner to compute patch-set and intermediate assignment [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-18885) document the behavioral differences between ZooKeeper and KRaft
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-16546) add docs to explain how to update cluster-wide default by Admin#incrementalAlterConfigs
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-12188) SaslAuthenticatorTest: assert the specific failure reason instead of catching any AssertionFailedError
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-12188) SaslAuthenticatorTest: assert the specific failure reason instead of catching any AssertionFailedError
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-21108) speed up StreamsUpgradeTestIntegrationTest
Jiayao Sun (Jira)
-
[jira] [Updated] (KAFKA-21108) speed up StreamsUpgradeTestIntegrationTest
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21108) speed up StreamsUpgradeTestIntegrationTest
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-21108) speed up StreamsUpgradeTestIntegrationTest
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-20579: Implement compression support for KIP-1332 [kafka]
via GitHub
-
Re: [PR] KAFKA-20532: Defensive trimming of min.insync.replicas in controller and kafka-topics to tolerate whitespace-contaminated configs [kafka]
via GitHub
-
[PR] KAFKA-21060: Make StickyAssignor aware of stateless vs stateful tasks [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-21006) Migrate AbstractApiVersionsRequestTest, SaslApiVersionsRequestTest, ApiVersionsRequestTest to server module
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-21107) String-valued class configuration fails when the context class loader cannot see kafka-clients
Ruimin MA (Jira)
-
[jira] [Updated] (KAFKA-21107) String-valued class configuration fails when the context class loader cannot see kafka-clients
Ruimin MA (Jira)
-
[jira] [Resolved] (KAFKA-20603) Replace MemoryLRUCache restoring flag with restore lifecycle hooks
Bill Bejeck (Jira)
-
Re: [PR] KAFKA-20921: Make ScramImage mechanism maps unmodifiable [kafka]
via GitHub
-
[PR] KAFKA-21107: Fall back to Kafka class loader when context lookup fails [kafka]
via GitHub