jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Assigned] (KAFKA-12506) Expand AdjustStreamThreadCountTest
Deep Golani (Jira)
[PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19369) Add group.share.assignors config
PoAn Yang (Jira)
[jira] [Created] (KAFKA-19369) Add group.share.assignors config
Andrew Schofield (Jira)
[PR] MINOR: LIST_CONFIG_RESOURCES in security.html [kafka]
via GitHub
Re: [PR] MINOR: LIST_CONFIG_RESOURCES in security.html [kafka]
via GitHub
[jira] [Commented] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage
PoAn Yang (Jira)
[jira] [Commented] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage
Kamal Chandraprakash (Jira)
[jira] [Updated] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs)
Alieh Saeedi (Jira)
[PR] MINOR: Add test for kafka-streams-groups.sh list [kafka]
via GitHub
Re: [PR] MINOR: Add test for kafka-streams-groups.sh list [kafka]
via GitHub
[jira] [Updated] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage
Kamal Chandraprakash (Jira)
[jira] [Updated] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage
Kamal Chandraprakash (Jira)
[PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete all groups) [3/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete internal topics) [3/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete internal topics) [3/N] [kafka]
via GitHub
Re: [PR] KAFKA-19244: Add support for kafka-streams-groups.sh options (delete internal topics) [3/N] [kafka]
via GitHub
[jira] [Created] (KAFKA-19368) DescribeLogDirs API should include the partition size in the remote storage
Kamal Chandraprakash (Jira)
[PR] MINOR: DelayedShareFetchTest mockStatic replaced close with try-with-resources [kafka]
via GitHub
Re: [PR] MINOR: replaced DelayedShareFetchTest mockStatic .close functionality with try-with-resources [kafka]
via GitHub
[jira] [Created] (KAFKA-19367) InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted
Artem Livshits (Jira)
Re: [PR] KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner. [kafka]
via GitHub
Re: [PR] KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner. [kafka]
via GitHub
Re: [PR] KAFKA-18854:Move DynamicConfig to server module [kafka]
via GitHub
Re: [PR] KAFKA-18299: Move connect data classes into a dedicated module [kafka]
via GitHub
Re: [PR] KAFKA-18299: Move connect data classes into a dedicated module [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19250) abortTransactions should not return abortable exception
Kaushik Raina (Jira)
[jira] [Resolved] (KAFKA-19176) Update Transactional producer to translate retriable into abortable exceptions
Kaushik Raina (Jira)
[jira] [Resolved] (KAFKA-19177) Return InvalidTxnStateException as Abortable for Transaction producer API
Kaushik Raina (Jira)
[PR] MINOR: Remove unnecessary checks. [kafka]
via GitHub
Re: [PR] MINOR: Remove unnecessary checks. [kafka]
via GitHub
[PR] KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update activeProducerState wih KRaft mechanism in ReplicaManagerTest [kafka]
via GitHub
[PR] KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower [kafka]
via GitHub
Re: [PR] KAFKA-18486 Remove becomeLeaderOrFollower from readFromLogWithOffsetOutOfRange and other related methods. [kafka]
via GitHub
[PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: State Updater thread not shutting down during teardown i… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Start state updater in task manager [kafka]
via GitHub
[jira] [Created] (KAFKA-19366) Do not resolve address in QuorumConfig and DynamicVoter
Jira
[PR] [WIP] MINOR: Refactor brokerContactTimesMs from AtomicLong to Long [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs from AtomicLong to Long [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs from AtomicLong to Long [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs from AtomicLong to Long [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
Re: [PR] MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer [kafka]
via GitHub
[jira] [Assigned] (KAFKA-18682) Designated Leadership Elections
Mahsa Seifikar (Jira)
[jira] [Created] (KAFKA-19365) Metric for Unclean Recoveries
Jonah Hooper (Jira)
[PR] KAFKA-19155: Update docs/security.html for streams-related RPCs [kafka]
via GitHub
Re: [PR] KAFKA-19155: Update docs/security.html for streams-related RPCs [kafka]
via GitHub
Re: [PR] KAFKA-19155: Update docs/security.html for streams-related RPCs [kafka]
via GitHub
Re: [PR] KAFKA-19155: Update docs/security.html for streams-related RPCs [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19155) Update docs/security.html for streams-related RPCs
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19362) Enhance share group assignor for homogeneous subscription type
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19364) Production-ready documentation
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19363) Enhance share group assignor for heterogeneous subscription type
Andrew Schofield (Jira)
[jira] [Closed] (KAFKA-19341) Execution of HighWatermarkUpdate failed
Patrik Kleindl (Jira)
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
Re: [PR] KAFKA-10551: Add topic id support to produce request and response [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19353) Preview documentation
Andrew Schofield (Jira)
Re: [PR] KAFKA-19250 : txnProducer.abortTransaction() API should not return abortable exception [kafka]
via GitHub
Re: [PR] KAFKA-19250 : txnProducer.abortTransaction() API should not return abortable exception [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19256) Only send IQ information on assignment changes
Lucas Brutschy (Jira)
[PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19338) Share coordinator read state and write state should return error, if the share partition is not initialized.
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-19318) Zookeeper-Kraft failing migration - RPC got timed out before it could be sent
dennis lucero (Jira)
[PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds [kafka]
via GitHub
Re: [PR] MINOR: Disable failing "Load Test Catalog" job on public forks [kafka]
via GitHub
[PR] KAFKA-15283:[2/2] Client support for OffsetFetch with topic ID [kafka]
via GitHub
[PR] KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private [kafka]
via GitHub
Re: [PR] KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private [kafka]
via GitHub
Re: [PR] KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private [kafka]
via GitHub
Re: [PR] KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private [kafka]
via GitHub
Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka]
via GitHub
Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka]
via GitHub
Re: [PR] KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access [kafka]
via GitHub
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Jira
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Justin Chen (Jira)
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Alyssa Huang (Jira)
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Jira
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Justin Chen (Jira)
[jira] [Commented] (KAFKA-19354) KRaft observer unable to recover after re-bootstrapping to follower
Jira
[PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka]
via GitHub
Re: [PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19358) Do not update share group offset reset strategy from VerifiableShareConsumer in share_consumer_test.py tests
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19349) Move CreateTopicsRequestWithPolicyTest to clients-integration-tests
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-18986) Properly handle configured topology soft-state using KIP-1101
Lucas Brutschy (Jira)
[jira] [Commented] (KAFKA-18986) Properly handle configured topology soft-state using KIP-1101
Lucas Brutschy (Jira)
[jira] [Resolved] (KAFKA-18904) Listing of configs for dynamically created resources is mysterious
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-18202) Reject non-zero sequences when there is no producer ID state on the partition for transactions v2 idempotent producers
Ritika Reddy (Jira)
Re: [PR] KAFKA-19026: AlterConfigPolicy incompatibility between ZK mode and KR… [kafka]
via GitHub
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Nat Wilson (Jira)
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Jun Rao (Jira)
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Donny Nadolny (Jira)
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Jun Rao (Jira)
[PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
Re: [PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
Re: [PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
Re: [PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
Re: [PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
Re: [PR] MINOR : Handle error for client telemetry push [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19361) document that `mapKey` does not break the compatibility
Ming-Yen Chung (Jira)
[jira] [Resolved] (KAFKA-19320) Add share_consume_bench_test.py system tests
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-16894) Define switch to enable share groups for preview
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19361) document that `mapKey` does not break the compatibility
Chia-Ping Tsai (Jira)
[PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
Re: [PR] KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 [kafka]
via GitHub
[PR] KAKFA-14895: (WIP) [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: (WIP) [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
Re: [PR] KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java [kafka]
via GitHub
[PR] KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy instead of using VerifiableShareConsumer flag [kafka]
via GitHub
Re: [PR] KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy instead of using VerifiableShareConsumer flag [kafka]
via GitHub
Re: [PR] KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy instead of using VerifiableShareConsumer flag [kafka]
via GitHub
Re: [PR] KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy instead of using VerifiableShareConsumer flag [kafka]
via GitHub
Re: [PR] KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy [kafka]
via GitHub
[jira] [Created] (KAFKA-19360) Remove Admin#listClientMetricsResources and related metric
PoAn Yang (Jira)
[jira] [Resolved] (KAFKA-19321) Add share_consumer_performance.py and related system tests
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-18820) CVE-2025-24970 [netty-handler]
Vishal (Jira)
[jira] [Commented] (KAFKA-19359) [8.8] [CVE-2025-48734] [commons-beanutils] [1.9.4]
Surojeet Ghosh (Jira)
[jira] [Commented] (KAFKA-19359) [8.8] [CVE-2025-48734] [commons-beanutils] [1.9.4]
Luke Chen (Jira)
[jira] [Commented] (KAFKA-19359) [8.8] [CVE-2025-48734] [commons-beanutils] [1.9.4]
Federico Valeri (Jira)
[jira] [Created] (KAFKA-19359) [8.8] [CVE-2025-48734] [commons-beanutils] [1.9.4]
Surojeet Ghosh (Jira)
[jira] [Updated] (KAFKA-19358) Do not update share group offset reset strategy from VerifiableShareConsumer in share_consumer_test.py tests
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-19358) do not update share group offset reset strategy from VerifiableShareConsumer in share_consumer_test.py tests
Chirag Wadhwa (Jira)
[jira] [Updated] (KAFKA-18904) Listing of configs for dynamically created resources is mysterious
PoAn Yang (Jira)
[PR] KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources [kafka]
via GitHub
Re: [PR] KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources [kafka]
via GitHub
Re: [PR] KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources [kafka]
via GitHub
Re: [PR] KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()
Shivsundar R (Jira)
[jira] [Resolved] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Shivsundar R (Jira)
[jira] [Commented] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()
Shivsundar R (Jira)
[jira] [Commented] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Shivsundar R (Jira)
[PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka]
via GitHub
Re: [PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka]
via GitHub
Re: [PR] KAFKA-19340: Move DelayedRemoteFetch to the storage module [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-19328) SharePartitionManagerTest testMultipleConcurrentShareFetches doAnswer chaining needs verification
jiseung (Jira)
[jira] [Resolved] (KAFKA-19355) Remove interBrokerListenerName from ClusterControlManager
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19352) PlaintextConsumerCommitTest > testCommitAsyncCompletedBeforeConsumerCloses [1] Type=Raft-Isolated
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19053) Remove FetchResponse#of which is not used in production anymore
Chia-Ping Tsai (Jira)
[PR] MINOR: Rename ambiguous method name [kafka]
via GitHub
Re: [PR] MINOR: Rename ambiguous method name [kafka]
via GitHub
Earlier messages
Later messages