jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Created] (KAFKA-19207) Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module
Chia-Ping Tsai (Jira)
[PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Simplify OffsetFetchRequest [kafka]
via GitHub
[PR] MINOR: Clean up CloseOptions [kafka]
via GitHub
Re: [PR] KAFKA-14464: Make resource leaks for MM2 resources more difficult [kafka]
via GitHub
Re: [PR] KAFKA-14464: Make resource leaks for MM2 resources more difficult [kafka]
via GitHub
Re: [PR] KAFKA-13152: Kip 770 buffer size fix [kafka]
via GitHub
Re: [PR] KAFKA-13152: Kip 770 buffer size fix [kafka]
via GitHub
Re: [PR] fix: replace an inefficient loop in kafka internals [kafka]
via GitHub
Re: [PR] fix: replace an inefficient loop in kafka internals [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KAFKA-19008 Remove scala version from artifacts [kafka]
via GitHub
Re: [PR] KAFKA-19008 Remove scala version from artifacts [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test [kafka]
via GitHub
[PR] Minor cleanup timewindowdeserializertest [kafka]
via GitHub
Re: [PR] Minor cleanup timewindowdeserializertest [kafka]
via GitHub
Re: [PR] MINOR: fix bug in TimeWindowedDeserializerTest [kafka]
via GitHub
Re: [PR] MINOR: fix bug in TimeWindowedDeserializerTest [kafka]
via GitHub
Re: [PR] MINOR: fix bug in TimeWindowedDeserializerTest [kafka]
via GitHub
Re: [PR] MINOR: fix bug in TimeWindowedDeserializerTest [kafka]
via GitHub
Re: [PR] MINOR: fix bug in TimeWindowedDeserializerTest [kafka]
via GitHub
[jira] [Updated] (KAFKA-19206) ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() previously failed
Kirk True (Jira)
[PR] KAFKA-19206: ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() previously failed [kafka]
via GitHub
[jira] [Updated] (KAFKA-19206) ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() failed
Kirk True (Jira)
[jira] [Updated] (KAFKA-19206) ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() failed
Kirk True (Jira)
[jira] [Created] (KAFKA-19206) AsyncKafkaConsumer hangs when NetworkClient fails authentication
Kirk True (Jira)
[PR] KAFKA-19087: Move TransactionState to transaction-coordinator module (wip) [kafka]
via GitHub
[PR] MINOR: update KafkaStreamsTelemetryIntegrationTest for Java17 [kafka]
via GitHub
Re: [PR] MINOR: update KafkaStreamsTelemetryIntegrationTest for Java17 [kafka]
via GitHub
[jira] [Created] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Kirk True (Jira)
[jira] [Updated] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Kirk True (Jira)
[jira] [Assigned] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
kangning.li (Jira)
[jira] [Created] (KAFKA-19205) inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion
Sushant Mahajan (Jira)
[PR] [WIP] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
[jira] [Updated] (KAFKA-19202) Enable KIP-1071 in streams system tests where it makes sense
Matthias J. Sax (Jira)
[PR] MINOR: Update apacheds to 2.0.0.AM27 [kafka]
via GitHub
Re: [PR] MINOR: Update apacheds to 2.0.0.AM27 [kafka]
via GitHub
Re: [PR] MINOR: Update apacheds to 2.0.0.AM27 [kafka]
via GitHub
Re: [PR] MINOR: Update apacheds to 2.0.0.AM27 [kafka]
via GitHub
[PR] MINOR: Update jgit to the latest version [kafka]
via GitHub
Re: [PR] MINOR: Update jgit to the latest version [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19203) Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19203) Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka]
via GitHub
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka]
via GitHub
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka]
via GitHub
Re: [PR] KAFKA-19026: add note in ZK to KRaft migration [kafka]
via GitHub
[PR] HOTFIX: Fix StreamThreadTest [kafka]
via GitHub
Re: [PR] HOTFIX: Fix StreamThreadTest [kafka]
via GitHub
[PR] MINOR: add repartitionSourceTopics to stream group desciption [kafka]
via GitHub
Re: [PR] MINOR: add repartitionSourceTopics to Streams group description [kafka]
via GitHub
Re: [PR] MINOR: add repartitionSourceTopics to Streams group description [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19202) Enable KIP-1071 in streams system tests where it makes sense
Lucas Brutschy (Jira)
[PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py [kafka]
via GitHub
[jira] [Created] (KAFKA-19202) Enable KIP-1071 in streams system tests where it makes sense
Lucas Brutschy (Jira)
[PR] Handle delete topics [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19131) Exception thrown while updating the RemoteLogReader threads
Kamal Chandraprakash (Jira)
[jira] [Resolved] (KAFKA-18889) Make records in ShareFetchResponse non-nullable
Apoorv Mittal (Jira)
[PR] HOTFIX: GroupMetadataManagerTest fails to compile [kafka]
via GitHub
Re: [PR] HOTFIX: GroupMetadataManagerTest fails to compile [kafka]
via GitHub
Re: [PR] HOTFIX: GroupMetadataManagerTest fails to compile [kafka]
via GitHub
[jira] [Commented] (KAFKA-19200) Indexes should be sanity checked on startup
Gaurav Narula (Jira)
[PR] HOTFIX: Add missing argument [kafka]
via GitHub
Re: [PR] HOTFIX: Add missing argument [kafka]
via GitHub
Re: [PR] HOTFIX: Add missing argument [kafka]
via GitHub
Re: [PR] KAFKA-17871: avoid blocking the herder thread when producer flushing hangs [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT/APPEND
Edoardo Comar (Jira)
[jira] [Comment Edited] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT/APPEND
Luke Chen (Jira)
[jira] [Comment Edited] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT/APPEND
Edoardo Comar (Jira)
[jira] [Comment Edited] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT/APPEND
Edoardo Comar (Jira)
[PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
Re: [PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
Re: [PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
Re: [PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
Re: [PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
Re: [PR] MINOR: Move request static validations to GroupCoordinatorService [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19201) Handle deletion of a topic which has initialised share-group state
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-19200) Indexes should be sanity checked on startup
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-19200) Indexes should be sanity checked on startup
Gaurav Narula (Jira)
Re: [PR] [WIP] KAFKA-19170: Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19170: Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19170: Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-19170: Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
[PR] MINOR: code cleanup GroupMetadataManagerTestContext [kafka]
via GitHub
Re: [PR] MINOR: code cleanup GroupMetadataManagerTestContext [kafka]
via GitHub
Re: [PR] KAFKA-13154 : Changes for the OffsetSpec.latest() to correctly represent the latest offset per partition [kafka]
via GitHub
Re: [PR] MINOR: Add __cluster_metadata topic to list of internal topics [kafka]
via GitHub
Re: [PR] KAFKA-17798 : Adding forbiddenApi check [kafka]
via GitHub
Re: [PR] KAFKA-10840: Propagating Authentication errors when client setup fails with AuthenticationException [kafka]
via GitHub
Re: [PR] KAFKA-15845: Detect leaked Kafka clients and servers with LeakTestingExtension [kafka]
via GitHub
Re: [PR] KAFKA-13468: Consumers may hang because IOException in Log#<init> does not trigger KafkaStorageException [kafka]
via GitHub
Re: [PR] KAFKA-13468: Consumers may hang because IOException in Log#<init> does not trigger KafkaStorageException [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19105) Add Audit Logging for Authentication Events with Performance Consideration
Azhar Ahmed (Jira)
[jira] [Resolved] (KAFKA-19081) Share session capacity and eviction
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-19192) Old bootstrap.metadata files cause problems with post-KAFKA-18601 servers
Jira
[jira] [Commented] (KAFKA-19105) Add Audit Logging for Authentication Events with Performance Consideration
Azhar Ahmed (Jira)
[jira] [Commented] (KAFKA-19105) Add Audit Logging for Authentication Events with Performance Consideration
lujie (Jira)
[jira] [Created] (KAFKA-19199) Add broker side handling for 2PC with keepPrepared logic
Ritika Reddy (Jira)
[jira] [Commented] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
HongYi Chen (Jira)
[jira] [Commented] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
HongYi Chen (Jira)
[PR] KAFKA-19091: Fix race condition in DelayedFutureTest [kafka]
via GitHub
Re: [PR] KAFKA-19091: Fix race condition in DelayedFutureTest [kafka]
via GitHub
Re: [PR] KAFKA-19091: Fix race condition in DelayedFutureTest [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false
Azhar Ahmed (Jira)
[jira] [Assigned] (KAFKA-19188) kafka-topics.sh --describe --> output is inconsistent immediately after cluster restart
Azhar Ahmed (Jira)
[jira] [Assigned] (KAFKA-19177) Return InvalidTxnStateException as Abortable for Transaction producer API
Azhar Ahmed (Jira)
[jira] [Commented] (KAFKA-19177) Return InvalidTxnStateException as Abortable for Transaction producer API
Azhar Ahmed (Jira)
[jira] [Commented] (KAFKA-19188) kafka-topics.sh --describe --> output is inconsistent immediately after cluster restart
Azhar Ahmed (Jira)
[jira] [Commented] (KAFKA-19194) IOException thrown while starting Kafka broker if a file is present inside kafka data directory.
Azhar Ahmed (Jira)
[jira] [Assigned] (KAFKA-13555) Consider number if input topic partitions for task assignment
Lorcan (Jira)
[PR] KAFKA-19198: Resolve NPE when topic assigned in share group is deleted [kafka]
via GitHub
Re: [PR] KAFKA-19198: Resolve NPE when topic assigned in share group is deleted [kafka]
via GitHub
[jira] [Commented] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-19184) Document kraft version upgrade
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19184) Document kraft version upgrade
Jira
[jira] [Assigned] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19198) Deletion of topic assigned to a share group can result in NPE
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-19091) Flaky test DelayedFutureTest#testDelayedFuture
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19091) Flaky test DelayedFutureTest#testDelayedFuture
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19091) Flaky test DelayedFutureTest#testDelayedFuture
Uladzislau Blok (Jira)
[jira] [Assigned] (KAFKA-19196) Check whether FakeLocalMetadataStore#addACLs needs to be thread-safe.
Nick Guo (Jira)
Re: [PR] KAFKA-18988: Connect Multiversion Support (Updates to status and metrics) [kafka]
via GitHub
Re: [PR] KAFKA-18988: Connect Multiversion Support (Updates to status and metrics) [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18671) Failed handling of fetch response should log an error message
Jira
[jira] [Updated] (KAFKA-19184) Document kraft version upgrade
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-16538) Support UpdateFeatures for kraft.version so we can go from static quorums to dynamic
Jira
[jira] [Resolved] (KAFKA-18992) kafka-features.sh wronly output `upgraded kraft.version to 1`
Jira
[jira] [Resolved] (KAFKA-19191) Don't load bootstrap.checkpoint files if the cluster is already bootstrapped
Jira
[PR] Minor small refactor in group coordinator [kafka]
via GitHub
Re: [PR] MINOR: Small refactor in group coordinator [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19110) Add missing unit test for Streams-consumer integration
PoAn Yang (Jira)
[PR] MINOR: Use meaningful name in AsyncKafkaConsumerTest [kafka]
via GitHub
Re: [PR] MINOR: Use meaningful name in AsyncKafkaConsumerTest [kafka]
via GitHub
Re: [PR] MINOR: Use meaningful name in AsyncKafkaConsumerTest [kafka]
via GitHub
[PR] MINOR: Improve member epoch mismatch logging for share groups [kafka]
via GitHub
Re: [PR] MINOR: Improve member epoch mismatch logging for share groups [kafka]
via GitHub
[jira] [Created] (KAFKA-19197) Automatic generate metric list in document
PoAn Yang (Jira)
[jira] [Created] (KAFKA-19196) Check whether FakeLocalMetadataStore#addACLs needs to be thread-safe.
Nick Guo (Jira)
[jira] [Assigned] (KAFKA-19195) In group describe operations all group IDs are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
[PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
Re: [PR] KAFKA-19195: Only send the right group ID subset to each GC shard [kafka]
via GitHub
[jira] [Updated] (KAFKA-19195) In group describe operations all group IDs are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19195) In group describe operations all group IDs are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19195) In group describe operations all group IDs are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19195) Group describe operations are forwarded to all group coordinator shards.
Lucas Brutschy (Jira)
[jira] [Commented] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-18794) Flaky test: KafkaShareConsumerTest.testVerifyFetchAndCloseImplicit
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-18170) Periodic snapshots for cold share partitions
Apoorv Mittal (Jira)
[jira] [Resolved] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-18021) Disabled MirrorCheckpointConnector throws RetriableException on task config generation
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-18007) MirrorCheckpointConnector fails with “Timeout while loading consumer groups” after upgrading to Kafka 3.9.0
Mickael Maison (Jira)
[jira] [Created] (KAFKA-19194) IOException thrown while starting Kafka broker if a file is present inside kafka data directory.
Srinath PS (Jira)
[PR] MINOR: Change KIP-932 log messages from early access to preview [kafka]
via GitHub
Re: [PR] MINOR: Change KIP-932 log messages from early access to preview [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Re: [PR] MINOR: improve JavaDocs for consumer CloseOptions [kafka]
via GitHub
Earlier messages
Later messages