jira
Thread
Date
Earlier messages
Messages by Thread
[PR] KAFKA-19214: Clean up use of Optionals in RequestManagers.entries() [kafka]
via GitHub
[jira] [Updated] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions
Jira
[jira] [Created] (KAFKA-19224) Faster HWM replication for ISR topic partitions
Jira
[jira] [Created] (KAFKA-19223) Explicit HWM replication
Jira
[PR] KAFKA-19182: Move SchedulerTest to server module [kafka]
via GitHub
[jira] [Created] (KAFKA-19222) Invalid FENCED_MEMBER_EPOCH error to ConsumerGroupHeartbeat
Travis Bischel (Jira)
[jira] [Assigned] (KAFKA-19213) Kafka java client ignores default properties
Kirk True (Jira)
[jira] [Assigned] (KAFKA-19221) IOException on log segment close shouldn't be ignored
Gaurav Narula (Jira)
[PR] KAFKA-19221: Propagate IOException on LogSegment#close [kafka]
via GitHub
Re: [PR] KAFKA-19221: Propagate IOException on LogSegment#close [kafka]
via GitHub
[jira] [Created] (KAFKA-19221) IOException on log segment close shouldn't be ignored
Gaurav Narula (Jira)
[jira] [Resolved] (KAFKA-16718) Add AdminClient.deleteShareGroupOffsets
Andrew Schofield (Jira)
[PR] KAFKA-16894: Correct definition of ShareVersion [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for client group configs [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for client group configs [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for client group configs [kafka]
via GitHub
[jira] [Updated] (KAFKA-19214) Clean up use of Optionals in RequestManagers.entries()
Kirk True (Jira)
[PR] KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test [kafka]
via GitHub
[PR] KAFKA-19204: Allow persister retry of initializing topics. [kafka]
via GitHub
[PR] KAFKA-19218: Add missing leader epoch to share group state summary response [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19220) add tests to ensure the internal configs don't return by public APIs by default
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19220) add tests to ensure the internal configs don't return by public APIs by default
kangning.li (Jira)
[jira] [Created] (KAFKA-19220) add tests to ensure the internal configs don't return by public APIs by default
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18068) Fixing typo in ProducerConfig
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable
Sushant Mahajan (Jira)
[jira] [Created] (KAFKA-19219) improve KRaft migration log
Luke Chen (Jira)
[jira] [Created] (KAFKA-19218) Add missing leader epoch to read share group state summary response
Andrew Schofield (Jira)
[PR] KAFKA-19210: resolved the flakiness in testShareGroupHeartbeatInitializeOnPartitionUpdate [kafka]
via GitHub
Re: [PR] KAFKA-19210: resolved the flakiness in testShareGroupHeartbeatInitializeOnPartitionUpdate [kafka]
via GitHub
[jira] [Created] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-19216) Eliminate flakiness in kafka.server.share.SharePartitionTest
Andrew Schofield (Jira)
[PR] MINOR : Update KafkaRaftClient.java INFO log [kafka]
via GitHub
Re: [PR] MINOR; Log remote replica id when rejecting vote [kafka]
via GitHub
[jira] [Assigned] (KAFKA-18068) Fixing typo in ProducerConfig
Ming-Yen Chung (Jira)
[PR] Minor printing share group describe result in sorted order [kafka]
via GitHub
[PR] KAFKA-19215: Handle share partition fetch lock cleanly in DelayedShareFetch to avoid a member incorrectly releasing a share partition's fetch lock [kafka]
via GitHub
[PR] HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest [kafka]
via GitHub
Re: [PR] HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest [kafka]
via GitHub
Re: [PR] HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest [kafka]
via GitHub
[jira] [Created] (KAFKA-19215) Handle share partition fetch lock cleanly in DelayedShareFetch to avoid a member incorrectly releasing a share partition's fetch lock
Abhinav Dixit (Jira)
[jira] [Resolved] (KAFKA-18288) Add support kafka-streams-groups.sh --describe
Alieh Saeedi (Jira)
[jira] [Resolved] (KAFKA-19173) Add `Feature` for streams groups
Matthias J. Sax (Jira)
Re: [PR] [KAFKA-15579] Create GetReplicaLogInfo* handlers [kafka]
via GitHub
[jira] [Resolved] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
TengYao Chi (Jira)
[jira] [Resolved] (KAFKA-19135) Add IQ Support - move from feature branch
Bill Bejeck (Jira)
[jira] [Commented] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
TengYao Chi (Jira)
[jira] [Created] (KAFKA-19214) Clean up use of Optionals in RequestManagers.entries()
Kirk True (Jira)
Re: [PR] MINOR; Log message for unexpected buffer allocation [kafka]
via GitHub
Re: [PR] MINOR; Log message for unexpected buffer allocation [kafka]
via GitHub
[PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
Re: [PR] MINOR: Improve docs for retries & cleanup [kafka]
via GitHub
[jira] [Commented] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
ASF GitHub Bot (Jira)
[jira] [Updated] (KAFKA-19182) Move SchedulerTest to server module
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19182) Move SchedulerTest to server module
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19182) Move SchedulerTest to server module
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19182) Move SchedulerTest to server module
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-19213) Kafka java client ignores default properties
Pas Filip (Jira)
[jira] [Updated] (KAFKA-19213) Kafka java client ignores default properties
Pas Filip (Jira)
[jira] [Created] (KAFKA-19213) Kafka java client ignores default properties
Pas Filip (Jira)
[PR] KAFKA-19202: Enable KIP-1071 in streams_broker_down_resilience_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_broker_down_resilience_test [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_broker_down_resilience_test [kafka]
via GitHub
[PR] KAFKA-19181-2: Increased offsets.commit.timeout.ms value as a temporary solution for the system test test_broker_failure failure [kafka]
via GitHub
Re: [PR] KAFKA-19181-2: Increased offsets.commit.timeout.ms value as a temporary solution for the system test test_broker_failure failure [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19204) Timeouts in coordinator runtime operations can break share group initialization and deletion
Sushant Mahajan (Jira)
[jira] [Commented] (KAFKA-19201) Handle deletion of a topic which has initialised share-group state
Sushant Mahajan (Jira)
[jira] [Assigned] (KAFKA-19201) Handle deletion of a topic which has initialised share-group state
Sushant Mahajan (Jira)
[jira] [Updated] (KAFKA-19020) Handle strict max fetch records in share fetch
Apoorv Mittal (Jira)
Re: [PR] MINOR: Cleanup build.gradle unused import and update the deprecated `archivePath` [kafka]
via GitHub
Re: [PR] MINOR: Cleanup build.gradle unused import and update the deprecated `archivePath` [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19182) Move SchedulerTest to server module
Chia-Ping Tsai (Jira)
[PR] KAFKA-19133: Support fetching for multiple remote fetch topic partitions in a single share fetch request [kafka]
via GitHub
[PR] [WIP] KAFKA-19145: Move Leader Endpoint [kafka]
via GitHub
[PR] KAFKA-19212: Fix ElectionWasClean bug when partition reassignment completes [kafka]
via GitHub
Re: [PR] KAFKA-19212: Fix ElectionWasClean bug when partition reassignment completes [kafka]
via GitHub
Re: [PR] KAFKA-19212: Correct the unclean leader election metric calculation [kafka]
via GitHub
Re: [PR] KAFKA-19212: Correct the unclean leader election metric calculation [kafka]
via GitHub
[jira] [Updated] (KAFKA-19212) Fix ElectionWasClean bug when partition reassignment completes
Calvin Liu (Jira)
[jira] [Created] (KAFKA-19212) Fix ElectionWasClean method bug when partition reassignment completes
Calvin Liu (Jira)
[PR] KAFKA-19078: Implement automatic controller addition to cluster metadata partition [kafka]
via GitHub
Re: [PR] KAFKA-19078: Implement automatic controller addition to cluster metadata partition [kafka]
via GitHub
Re: [PR] KAFKA-16505: Add source raw key and value [kafka]
via GitHub
[PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
Re: [PR] KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk [kafka]
via GitHub
[jira] [Commented] (KAFKA-19182) Move SchedulerTest to server module
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-19182) Move SchedulerTest to server module
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
Uladzislau Blok (Jira)
[jira] [Assigned] (KAFKA-19034) Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module
HongYi Chen (Jira)
[PR] KAFKA-16718-4/n: ShareGroupCommand changes for DeleteShareGroupOffsets admin call [kafka]
via GitHub
Re: [PR] KAFKA-16718-4/n: ShareGroupCommand changes for DeleteShareGroupOffsets admin call [kafka]
via GitHub
Re: [PR] KAFKA-16718-4/n: ShareGroupCommand changes for DeleteShareGroupOffsets admin call [kafka]
via GitHub
[PR] KAFKA-18666: Controller-side monitoring for broker shutdown and startup [kafka]
via GitHub
[PR] MINOR: Remove unused erroneous code from test [kafka]
via GitHub
Re: [PR] MINOR: Remove unused erroneous code from test [kafka]
via GitHub
[PR] KAFKA-19202: Enable KIP-1071 in streams_broker_bounce_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_broker_bounce_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_broker_bounce_test.py [kafka]
via GitHub
Re: [PR] KAFKA-19202: Enable KIP-1071 in streams_broker_bounce_test.py [kafka]
via GitHub
[jira] [Created] (KAFKA-19211) Connect Storage Topics Sharing Across Clusters
Pritam Kumar (Jira)
Re: [PR] MINOR cleanup log related test [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19210) investigate flakiness in GroupMetadataManagerTest.testShareGroupHeartbeatInitializeOnPartitionUpdate
Chirag Wadhwa (Jira)
[jira] [Created] (KAFKA-19210) investigate flakiness in GroupMetadataManagerTest.testShareGroupHeartbeatInitializeOnPartitionUpdate
Chirag Wadhwa (Jira)
[jira] [Assigned] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
ShihYuanLin (Jira)
[PR] MINOR: Convert streams group options to consumer group options in Admin APIs [kafka]
via GitHub
[PR] KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module [kafka]
via GitHub
[jira] [Created] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
Luke Chen (Jira)
[jira] [Updated] (KAFKA-19209) "index.interval.bytes" config doc should also mention time index
Luke Chen (Jira)
[PR] KAFKA-18855: Slice API for MemoryRecords [kafka]
via GitHub
Re: [PR] KAFKA-18855: Slice API for MemoryRecords [kafka]
via GitHub
Re: [PR] KAFKA-18855: Slice API for MemoryRecords [kafka]
via GitHub
Re: [PR] KAFKA-19026: AlterConfigPolicy incompatibility between ZK mode and KR… [kafka]
via GitHub
Re: [PR] KAFKA-18337: KafkaProducer Memory Leak in JmxReporter Class [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout [kafka]
via GitHub
Re: [PR] KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic consumer and async consumer with zero timeout [kafka]
via GitHub
[PR] KAFKA-19208: KStream-GlobalKTable join should not drop left-null-key record [kafka]
via GitHub
Re: [PR] KAFKA-19208: KStream-GlobalKTable join should not drop left-null-key record [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19208) KStream-GlobalKTable join should not drop left-null-key record
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19208) KStream-GlobalKTable join should not drop left-null-key record
Matthias J. Sax (Jira)
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
Re: [PR] (WIP) MINOR: Move logDirs config out of KafkaConfig [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-19125) Implement Large message reference-based Serializer
Ivan Kulaga (Jira)
[jira] [Comment Edited] (KAFKA-19125) Implement Large message reference-based Serializer
Omnia Ibrahim (Jira)
[jira] [Resolved] (KAFKA-19183) Replace Pool with ConcurrentHashMap
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-19125) Implement Large message reference-based Serializer
Omnia Ibrahim (Jira)
Re: [PR] KAFKA-17423 Trie implementation [kafka]
via GitHub
Re: [PR] KAFKA-17423 Trie implementation [kafka]
via GitHub
[PR] KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID [kafka]
via GitHub
Re: [PR] KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID [kafka]
via GitHub
[PR] MINOR: Cleanup OffsetFetchRequest/Response in MessageTest [kafka]
via GitHub
Re: [PR] MINOR: Cleanup OffsetFetchRequest/Response in MessageTest [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19178) Replace Vector by ArrayList for PluginClassLoader#getResources
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19170 Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
Re: [PR] KAFKA-19170 Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
[PR] KAFKA-17826 Consumer#offsetsForTimes should not return null value [kafka]
via GitHub
[jira] [Commented] (KAFKA-19125) Implement Large message reference-based Serializer
Ivan Kulaga (Jira)
[jira] [Commented] (KAFKA-19125) Implement Large message reference-based Serializer
Omnia Ibrahim (Jira)
[jira] [Commented] (KAFKA-19125) Implement Large message reference-based Serializer
Ivan Kulaga (Jira)
[jira] [Commented] (KAFKA-19125) Implement Large message reference-based Serializer
Omnia Ibrahim (Jira)
[PR] KAFKA-19207: Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module [kafka]
via GitHub
[PR] KAFKA-19168: MirrorMaker kafka_metrics_count metric is always incorrect [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19207) Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module
PoAn Yang (Jira)
[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
Earlier messages