jira
Thread
Date
Later messages
Messages by Date
2024/08/29
[jira] [Commented] (KAFKA-17331) Throw/return unsupported version exception if the server/client does NOT support EarliestLocalSpec and LatestTieredSpec
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16142) Update metrics documentation for errors
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16816) Remove unneeded FencedInstanceId support on commit path for new consumer
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15320) Document event queueing patterns
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16110) Document and publicize performance test results for AsyncKafkaConsumer
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15864) Add more tests asserting the log-start-offset, local-log-start-offset, and HW/LSO/LEO in rolling over segments with tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15320) Document event queueing patterns
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16816) Remove unneeded FencedInstanceId support on commit path for new consumer
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15864) Add more tests asserting the log-start-offset, local-log-start-offset, and HW/LSO/LEO in rolling over segments with tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16110) Document and publicize performance test results for AsyncKafkaConsumer
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15301) [Tiered Storage] Historically compacted topics send request to remote for active segment during consume
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-14892) Harmonize package names in storage module
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15301) [Tiered Storage] Historically compacted topics send request to remote for active segment during consume
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-14892) Harmonize package names in storage module
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15553) Review consumer positions update
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread?
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15553) Review consumer positions update
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp()
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp()
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread?
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-9578) Kafka Tiered Storage - System Tests
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-9578) Kafka Tiered Storage - System Tests
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15646) Update ReassignPartitionsIntegrationTest once JBOD available
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15646) Update ReassignPartitionsIntegrationTest once JBOD available
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16580) Write simulation tests for kraft membership change
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16580) Write simulation tests for kraft membership change
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-14482) Move LogLoader to storage module
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15994) Add complex example compose file
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-14482) Move LogLoader to storage module
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures.
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15994) Add complex example compose file
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-17064) New consumer assign should update assignment in background thread
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-17064) New consumer assign should update assignment in background thread
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Comment Edited] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records.
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-16623) KafkaAsyncConsumer system tests warn about revoking partitions that weren't previously assigned
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
Colin McCabe (Jira)
2024/08/29
[jira] [Commented] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
Colin McCabe (Jira)
2024/08/29
[jira] [Comment Edited] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable
Colin McCabe (Jira)
2024/08/29
[jira] [Updated] (KAFKA-17412) Doc the different behavior of `unclean.leader.election.enable` in KRaft
Colin McCabe (Jira)
2024/08/29
Re: [PR] KAFKA-12670: support unclean.leader.election.enable in KRaft mode [kafka]
via GitHub
2024/08/29
[jira] [Resolved] (KAFKA-12670) KRaft support for unclean.leader.election.enable
Colin McCabe (Jira)
2024/08/29
Re: [PR] KAFKA-12670: KRaft support for unclean.leader.election.enable [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-12670: KRaft support for unclean.leader.election.enable [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17287: Added integration tests for ShareConsumer [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17413; Re-introduce `group.version` feature flag [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17377: Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe [kafka]
via GitHub
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
Re: [PR] KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreListener [kafka]
via GitHub
2024/08/29
[jira] [Resolved] (KAFKA-17390) Remove broker-list in GetOffsetShell
Chia-Ping Tsai (Jira)
2024/08/29
Re: [PR] KAFKA-17390:Remove broker-list in GetOffsetShell [kafka]
via GitHub
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17066: new consumer updateFetchPositions all in background thread [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreListener [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
[jira] [Comment Edited] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
Re: [PR] KAFKA-17367: Share coordinator impl. Broker side code. [2/N] [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR: add ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR fix for opt-in flag for Github build [kafka]
via GitHub
2024/08/29
[jira] [Commented] (KAFKA-17428) remote segments deleted in RLMCopyTask stays `COPY_SEGMENT_START` state
Federico Valeri (Jira)
2024/08/29
Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17377: Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR fix for opt-in flag for Github build [kafka]
via GitHub
2024/08/29
[jira] [Created] (KAFKA-17443) Create a tool to manipulate share-group state snapshots for recovery purposes
Andrew Schofield (Jira)
2024/08/29
Re: [PR] KAFKA-17433 Add a deflake Github action [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR fix for opt-in flag for Github build [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17442: Handled persister errors with write async calls (KIP-932) [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) [kafka]
via GitHub
2024/08/29
[PR] KAFKA-17347: Add missing client-metrics option to kafka-configs.sh [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreListener [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-14572: Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-14572: Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR fix for opt-in flag for Github build [kafka]
via GitHub
2024/08/29
[PR] KAFKA-15859: Introduce remote.list.offsets.request.timeout.ms dynamic config [kafka]
via GitHub
2024/08/29
[PR] KAFKA-14772: Add ConsumerGroupHeartbeat and ConsumerGroupDescribe API to AuthorizerIntegrationTest [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16993: Flaky test shouldInvokeUserDefinedGlobalStateRestoreListener [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17218: kafka-consumer-groups should handle describe groups with deleted topics [kafka]
via GitHub
2024/08/29
[PR] MINOR: Add integration test for ReassignPartitionsCommand#curReassignmentsToString [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-15853: Move KafkaConfig to server module [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-15853: Move KafkaConfig to server module [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17437: Upgrade commons-validator from 1.7 to 1.9.0 [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17411: Create local state Standbys on start [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17433 Add a deflake Github action [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17433 Add a deflake Github action [kafka]
via GitHub
2024/08/29
[PR] KAFKA-14482: Move LogLoader to storage module [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17435:remove use.incremental.alter.configs [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17137[part-5]: Ensure Admin APIs are properly tested [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17316: Standard authorizer refactor [kafka]
via GitHub
2024/08/29
[jira] [Resolved] (KAFKA-17388) Remove broker-list in VerifiableProducer
Chia-Ping Tsai (Jira)
2024/08/29
Re: [PR] Minor: Add "experimental message" for the native docker image [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17388: Remove broker-list in VerifiableProducer [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17400: Added share fetch purgatory for delaying share fetch requests which cannot be completed because of reaching record lock partition limit [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17400: Added share fetch purgatory for delaying share fetch requests which cannot be completed because of reaching record lock partition limit [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]
via GitHub
2024/08/29
[PR] Minor: Add "experimental message" for the native docker image [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17170: Add test to ensure new consumer acks reconciled assignment even if first HB with ack lost [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA- 12834 : Removed Deprecated method under MockProcessorContext [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17442: Handled persister errors with write async calls (KIP-932) [kafka]
via GitHub
2024/08/29
Re: [PR] Minor: Add "experimental message" for the native docker image [kafka]
via GitHub
2024/08/29
[PR] Add "experimental message" for the native docker image [kafka]
via GitHub
2024/08/29
[jira] [Created] (KAFKA-17442) Implement persister error handling and make write calls async
Apoorv Mittal (Jira)
2024/08/29
[jira] [Resolved] (KAFKA-17396) Fix releasing of session on clients final epoch
Apoorv Mittal (Jira)
2024/08/29
[jira] [Resolved] (KAFKA-17283) Add integration test for Share Group heartbeat
Apoorv Mittal (Jira)
2024/08/29
[PR] KAFKA-17425: Improve coexistence of consumer and share groups [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR: add helper function for clusterInstance [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16863 : Deprecate default exception handlers [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17400: Added share fetch purgatory for delaying share fetch requests which cannot be completed because of reaching record lock partition limit [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17400: Added share fetch purgatory for delaying share fetch requests which cannot be completed because of reaching record lock partition limit [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17400: Added share fetch purgatory for delaying share fetch requests which cannot be completed because of reaching record lock partition limit [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16863 : Deprecate default exception handlers [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16863 : Deprecate default exception handlers [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16863 : Deprecate default exception handlers [kafka]
via GitHub
2024/08/29
[jira] [Resolved] (KAFKA-17413) Re-introduce `group.version` feature flag
David Jacot (Jira)
2024/08/29
[jira] [Assigned] (KAFKA-14772) Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest
Lan Ding (Jira)
2024/08/29
Re: [PR] KAFKA-17413; Re-introduce `group.version` feature flag [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17413; Re-introduce `group.version` feature flag [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16057 : Change the configuration for adminclient connections.max.idle.ms to 9 minutes [kafka]
via GitHub
2024/08/29
Re: [PR] MINOR: add helper function for clusterInstance [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16057 : Change the configuration for adminclient connections.max.idle.ms to 9 minutes [kafka]
via GitHub
2024/08/29
[jira] [Commented] (KAFKA-12834) Remove Deprecated method MockProcessorContext#setTimestamp
Ksolves India Limited (Jira)
2024/08/29
Re: [PR] KAFKA-17053: Restructure build.gradle to configure publishing last [kafka]
via GitHub
2024/08/29
Re: [PR] KAFKA-16327: Removed Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION [kafka]
via GitHub
2024/08/28
Re: [PR] MINOR: add helper function for clusterInstance [kafka]
via GitHub
2024/08/28
[jira] [Assigned] (KAFKA-17440) Convert QuorumTestHarness to use PreboundSocketFactoryManager
Chia-Ping Tsai (Jira)
2024/08/28
[jira] [Resolved] (KAFKA-17062) RemoteLogManager - RemoteStorageException causes data loss
Luke Chen (Jira)
2024/08/28
Re: [PR] KAFKA-17062: handle dangling "copy_segment_start" state when deleting remote logs [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-17062: handle dangling "copy_segment_start" state when deleting remote logs [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-17435:remove use.incremental.alter.configs [kafka]
via GitHub
2024/08/28
Re: [PR] KAFK-17401: Add config for purge interval for Share Fetch Purgatory [kafka]
via GitHub
2024/08/28
[jira] [Commented] (KAFKA-14772) Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest
David Jacot (Jira)
2024/08/28
Re: [PR] KAFKA-12829: Remove deprecated Topology#addGlobalStore of old Processor API [kafka]
via GitHub
2024/08/28
Re: [PR] [DO NOT MERGE] PoC for ProcessingExceptionHandler [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-12829: Remove the deprecated method `init(ProcessorContext, StateStore)` from the `StateStore` interface [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator [kafka]
via GitHub
2024/08/28
[jira] [Commented] (KAFKA-14772) Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest
Lan Ding (Jira)
2024/08/28
Re: [PR] KAFKA-17331: Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec [kafka]
via GitHub
2024/08/28
Re: [PR] KAFKA-17064: New consumer assign should update assignment in background thread [kafka]
via GitHub
Later messages