jira
Thread
Date
Later messages
Messages by Thread
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
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
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] MINOR: Some cleanups in group coordinator's intergration tests [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
Re: [PR] KAFKA-16729: Support isolation level for share consumer [kafka]
via GitHub
[jira] [Created] (KAFKA-19021) Broker should not be allowed to be promoted to controller
Jira
Re: [PR] MINOR: Optimize the 'waitForVerifyAssignment' method log output [kafka]
via GitHub
Re: [PR] KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups` [kafka]
via GitHub
Re: [PR] KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups` [kafka]
via GitHub
Re: [PR] KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups` [kafka]
via GitHub
Re: [PR] KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups` [kafka]
via GitHub
Re: [PR] KAFKA-19024 Enhance the client behaviour when it tries to exceed the `group.share.max.groups` [kafka]
via GitHub
Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka]
via GitHub
Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka]
via GitHub
Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka]
via GitHub
Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka]
via GitHub
[jira] [Created] (KAFKA-19074) Remove the cached responseData from ShareFetchResponse
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] KAFKA-18888: Add KIP-877 support to Authorizer [kafka]
via GitHub
Re: [PR] MINOR: Remove unused `ApiKeys.minRequiredInterBrokerMagic` [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
Re: [PR] KAFKA-19004:Move DelayedDeleteRecords to server-common module [kafka]
via GitHub
[PR] MINOR: FindCoordinator API does not lookup partition for share partition key correctly [kafka]
via GitHub
Re: [PR] KAFKA-18935: Ensure brokers do not return null records in FetchResponse [kafka]
via GitHub
Re: [PR] KAFKA-18935: Ensure brokers do not return null records in FetchResponse [kafka]
via GitHub
Re: [PR] MINOR: Cleanup test-common-runtime module [kafka]
via GitHub
[jira] [Created] (KAFKA-19051) Fix implicit acknowledgement cannot be override when RecordDeserializationException occurs
Jira
Re: [PR] KAFKA-19062: Port changes from KAFKA-18645 to share-consumers [kafka]
via GitHub
[jira] [Commented] (KAFKA-19079) KIP-890 Cleanups
oshione gabriel esiemokhai (Jira)
Re: [PR] MINOR: migrate BrokerCompressionTest to storage module [kafka]
via GitHub
[jira] [Updated] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT
Edoardo Comar (Jira)
Re: [PR] KAFKA-16616: refactor mergeWith and updatePartitionLeadership [kafka]
via GitHub
Re: [PR] KAFKA-18991: FetcherThread should match leader epochs between fetch request and fetch state [kafka]
via GitHub
Re: [PR] KAFKA-19025: Reuse LZ4 buffers for compression [kafka]
via GitHub
Re: [PR] KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests [kafka]
via GitHub
Re: [PR] KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests [kafka]
via GitHub
[PR] Mar 18 Testing [kafka-merge-queue-sandbox]
via GitHub
[PR] MINOR: Update Mockito on 3.9 for Java 23 support [kafka]
via GitHub
Re: [PR] KAFKA-19053: Remove FetchResponse#of which is not used in production … [kafka]
via GitHub
Re: [PR] KAFKA-19053: Remove FetchResponse#of which is not used in production … [kafka]
via GitHub
Re: [PR] Trying again [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] [MINOR] Cleanup Server Common Module [kafka]
via GitHub
Re: [PR] KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer [kafka]
via GitHub
[jira] [Resolved] (KAFKA-18827) Initialize share group state impl
Sushant Mahajan (Jira)
[jira] [Commented] (KAFKA-19068) Eliminate the duplicate type check in creating ControlRecord
Nick Guo (Jira)
[PR] KAFKA-15931: Cancel RemoteLogReader gracefully [kafka]
via GitHub
[jira] [Updated] (KAFKA-19012) Messages ending up on the wrong topic
Kirk True (Jira)
Re: [PR] Another change but this time with a long title. What happens if the title is over 72 characters? I guess we'll find out. [kafka-merge-queue-sandbox]
via GitHub
Re: [PR] Minor: Add functionalinterface to the producer callback [kafka]
via GitHub
Re: [PR] Minor: Add functionalinterface to the producer callback [kafka]
via GitHub
Re: [PR] MINOR: Fix upgrade finalization flag [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets [kafka]
via GitHub
[jira] [Created] (KAFKA-19030) Remove metricNamePrefix from RequestChannel
Chia-Ping Tsai (Jira)
Re: [PR] MINOR VerifableProducer ducktape can set idempotency and retries [kafka]
via GitHub
Re: [PR] MINOR VerifableProducer ducktape can set idempotency and retries [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19003) Add force-terminate feature to kafka-transactions CLI and Admin Client
Ritika Reddy (Jira)
[jira] [Commented] (KAFKA-15580) KIP-966: Unclean Recovery
Jonah Hooper (Jira)
Re: [PR] KAFKA-18845: Fix flaky QuorumControllerTest#testUncleanShutdownBrokerElrEnabled [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19080) The constraint on segment.ms is not enforced at topic level
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-14486: Move LogCleanerManager to storage module [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-17354) StreamThread::setState race condition causes java.lang.RuntimeException: State mismatch PENDING_SHUTDOWN different from STARTING
Ao Li (Jira)
Re: [PR] KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers [kafka]
via GitHub
Re: [PR] KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers [kafka]
via GitHub
Re: [PR] KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers [kafka]
via GitHub
Re: [PR] KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers [kafka]
via GitHub
Re: [PR] KAFKA-18329; [1/3] Delete old group coordinator (KIP-848) [kafka]
via GitHub
[jira] [Created] (KAFKA-19056) Move EndToEndClusterIdTest to server module
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19055) Cleanup the 0.10.x information from clients module
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-18329; [2/3] Delete old group coordinator (KIP-848) [kafka]
via GitHub
Re: [PR] KAFKA-18329; [2/3] Delete old group coordinator (KIP-848) [kafka]
via GitHub
Re: [PR] KAFKA-18329; [2/3] Delete old group coordinator (KIP-848) [kafka]
via GitHub
[jira] [Updated] (KAFKA-19061) Add ACL changes to enable role based 2PC
Ritika Reddy (Jira)
[jira] [Commented] (KAFKA-12715) ACL authentication, Host field support IP network segment
Jaideep Cuttamanchi (Jira)
Re: [PR] KAFKA-18713: Fix left join bug by using DELETE_KEY_NO_PROPAGATE [kafka]
via GitHub
Re: [PR] MINOR: leverage preProcessParsedConfig within AbstractConfig [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] KAFKA-18891: KIP-877 add support for RemoteLogMetadataManager and RemoteStorageManager [kafka]
via GitHub
Re: [PR] MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest [kafka]
via GitHub
Re: [PR] MINOR: Add documentation about KIP-405 remote reads serving just one partition per FetchRequest [kafka]
via GitHub
[jira] [Resolved] (KAFKA-17431) KRaft servers require valid static socketserver configuration to start
Kevin Wu (Jira)
Re: [PR] KAFKA-18946: Move BrokerReconfigurable and DynamicProducerStateManagerConfig to server module [kafka]
via GitHub
Re: [PR] KAFKA-18761: [2/N] List share group offsets with state and auth [kafka]
via GitHub
Re: [PR] KAFKA-18761: [2/N] List share group offsets with state and auth [kafka]
via GitHub
Re: [PR] MINOR: Add Functional Interface annotation to interfaces used by Lambdas [kafka]
via GitHub
Re: [PR] MINOR: Add Functional Interface annotation to interfaces used by Lambdas [kafka]
via GitHub
Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]
via GitHub
Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]
via GitHub
Re: [PR] KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator [kafka]
via GitHub
Re: [PR] KAFKA-17662: config.providers configuration missing from the docs [kafka]
via GitHub
Re: [PR] KAFKA-17662: config.providers configuration missing from the docs [kafka]
via GitHub
Re: [PR] KAFKA-17662: config.providers configuration missing from the docs [kafka]
via GitHub
Re: [PR] KAFKA-17662: config.providers configuration missing from the docs [kafka]
via GitHub
Re: [PR] KAFKA-17662: config.providers configuration missing from the docs [kafka]
via GitHub
[jira] [Updated] (KAFKA-19003) Add force-terminate command to kafka-transactions CLI
Ritika Reddy (Jira)
[jira] [Updated] (KAFKA-19003) Add force-terminate command to kafka-transactions CLI
Ritika Reddy (Jira)
[PR] Another small update [kafka-merge-queue-sandbox]
via GitHub
[PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR: Use readable interface to parse response [kafka]
via GitHub
Re: [PR] MINOR:modify scala $var to java string [kafka]
via GitHub
Re: [PR] MINOR:modify scala $var to java string [kafka]
via GitHub
Re: [PR] MINOR:modify scala $var to java string [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
Re: [PR] KAFKA-18959: increase the num_workers from 9 to 12 [kafka]
via GitHub
Re: [PR] KAFKA-18959: increase the num_workers from 9 to 12 [kafka]
via GitHub
[jira] [Commented] (KAFKA-19026) AlterConfigPolicy incompatibility between ZK mode and KRaft mode when using AlterConfigOp.OpType.SUBTRACT
Edoardo Comar (Jira)
Later messages