jira
Thread
Date
Earlier messages
Messages by Thread
[PR] KAFKA-17602: Remove `ConfigUtils.translateDeprecatedConfigs` from JmxReporter [kafka]
via GitHub
[PR] [WIP] KAFKA-16339: [3/4 KStream#transformValues] Remove Deprecated "transformer" methods and classes [kafka]
via GitHub
[PR] KAFKA-14563: add transaction feature version supports (#117) [kafka]
via GitHub
[jira] [Commented] (KAFKA-17602) Remove `ConfigUtils.translateDeprecatedConfigs` from JmxReporter
kangning.li (Jira)
Re: [PR] KAFKA-16469: Metadata schema checker [kafka]
via GitHub
Re: [PR] KAFKA-16469: Metadata schema checker [kafka]
via GitHub
Re: [PR] KAFKA-16469: Metadata schema checker [kafka]
via GitHub
[jira] [Created] (KAFKA-17604) Describe quorum output missing added voters endpoints
Alyssa Huang (Jira)
[jira] [Assigned] (KAFKA-17604) Describe quorum output missing added voters endpoints
Alyssa Huang (Jira)
[jira] [Resolved] (KAFKA-17465) Refactor getMembersFromGroup to be non-blocking
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17465) Refactor getMembersFromGroup to be non-blocking
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17603) KRaftMigrationDriverTest testNoDualWriteBeforeMigration became flaky
David Arthur (Jira)
[jira] [Updated] (KAFKA-17603) KRaftMigrationDriverTest testNoDualWriteBeforeMigration became flaky
David Arthur (Jira)
[jira] [Created] (KAFKA-17603) KRaftMigrationDriverTest testNoDualWriteBeforeMigration became flaky
David Arthur (Jira)
[jira] [Resolved] (KAFKA-17585) `offsetResetStrategyTimestamp` should return `long` instead of `Long`
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17512) Move LogSegmentTest to storage module
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17530) Remove blacklist/whitelist from ReplaceField
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17602) Remove `ConfigUtils.translateDeprecatedConfigs` from JmxReporter
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests
Arpit Goyal (Jira)
[jira] [Assigned] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests
Kirk True (Jira)
[jira] [Commented] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests
Arpit Goyal (Jira)
[jira] [Commented] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests
Kirk True (Jira)
[jira] [Updated] (KAFKA-17600) Add nextOffsets to the ConsumerRecords
Matthias J. Sax (Jira)
[jira] [Comment Edited] (KAFKA-17601) Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
Tamas Kornai (Jira)
[jira] [Commented] (KAFKA-17601) Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17601) Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
Tamas Kornai (Jira)
[jira] [Commented] (KAFKA-17601) Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
Tamas Kornai (Jira)
[PR] KAFKA-17516: Synonyms for client metrics configs [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-17516) Client metrics configuration resources default configs not shown by kafka-configs.sh
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-17601) Inter-broker connections do not expose their clientSoftwareName and clientSoftwareVersion tags
Tamas Kornai (Jira)
Re: [PR] MINOR: Using rocksdb's prefixScan in fk joins for better performances [kafka]
via GitHub
[PR] KAFKA-17473 Speed Up ClientTelemetryTest [kafka]
via GitHub
Re: [PR] KAFKA-14562 [1/2]: Implement epoch bump after every transaction [kafka]
via GitHub
Re: [PR] KAFKA-14562 [1/2]: Implement epoch bump after every transaction [kafka]
via GitHub
Re: [PR] KAFKA-14562 [1/2]: Implement epoch bump after every transaction [kafka]
via GitHub
[jira] [Resolved] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17600) Add nextOffsets to the ConsumerRecords
Alieh Saeedi (Jira)
[PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
Re: [PR] KAFKA-17469: Moved share external interfaces to share module. [kafka]
via GitHub
[jira] [Commented] (KAFKA-5238) BrokerTopicMetrics can be recreated after topic is deleted
James Cheng (Jira)
[jira] [Commented] (KAFKA-5238) BrokerTopicMetrics can be recreated after topic is deleted
Edoardo Comar (Jira)
[jira] [Commented] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest
Josep Prat (Jira)
[jira] [Commented] (KAFKA-16491) Flaky test: randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology] – org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest
Josep Prat (Jira)
[PR] KAFKA-17375: Fix reassignment after segment.bytes changes [kafka]
via GitHub
[PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
Re: [PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
Re: [PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
Re: [PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
Re: [PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
Re: [PR] KAFKA-17542: Use actions/labeler for automatic PR labeling - part 2 [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-4566) Can't Symlink to Kafka bins
Alex Russell (Jira)
[jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins
Alex Russell (Jira)
[jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins
Alex Russell (Jira)
[jira] [Assigned] (KAFKA-17572) Clear build scan PR status when re-running the tests
Chia-Ping Tsai (Jira)
[PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
Re: [PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
Re: [PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
Re: [PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
Re: [PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
Re: [PR] KAFKA-16331: remove KafkaClientSupplier from StreamsProducer [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Comment Edited] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Fake (Jira)
[jira] [Updated] (KAFKA-17581) AsyncKafkaConsumer can't unsubscribe invalid topics
Kirk True (Jira)
[PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
Re: [PR] KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations [kafka]
via GitHub
[jira] [Updated] (KAFKA-17584) Fix incorrect synonym handling for dynamic log configurations
Colin McCabe (Jira)
[jira] [Updated] (KAFKA-17584) Incorrect synonym handling for dynamic log configurations
Colin McCabe (Jira)
[PR] KAFKA-17592: Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC [kafka]
via GitHub
Re: [PR] KAFKA-17592: Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC [kafka]
via GitHub
Re: [PR] KAFKA-17592: Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC [kafka]
via GitHub
Re: [PR] KAFKA-17592: Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC [kafka]
via GitHub
Re: [PR] KAFKA-17592: Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC [kafka]
via GitHub
[jira] [Commented] (KAFKA-16820) Kafka Broker fails to connect to Kraft Controller with no DNS matching
Arushi Helms (Jira)
[PR] MINOR: add a space for kafka.metrics.polling.interval.secs [kafka]
via GitHub
Re: [PR] MINOR: add a space for kafka.metrics.polling.interval.secs description [kafka]
via GitHub
Re: [PR] MINOR: add a space for kafka.metrics.polling.interval.secs description [kafka]
via GitHub
[jira] [Commented] (KAFKA-17576) Fix all references to kraft/server.properties to use reconfig-server.properties
Jira
[jira] [Updated] (KAFKA-17599) Update Consumer Subscription with Current Assignment Before Partition Revocation
Pritam Kumar (Jira)
[PR] Updating consumer subscription object with the latest subscription before "invokePartitionRevoked". [kafka]
via GitHub
Re: [PR] Updating consumer subscription object with the latest subscription before "invokePartitionRevoked". [kafka]
via GitHub
[jira] [Resolved] (KAFKA-17471) Speed Up ResetConsumerGroupOffsetTest
Jira
[jira] [Commented] (KAFKA-17471) Speed Up ResetConsumerGroupOffsetTest
Jira
Re: [PR] KAFKA-16959: ConfigCommand should allow to define both `entity-default` and `entity-name` [kafka]
via GitHub
[jira] [Created] (KAFKA-17599) Update Consumer Subscription with Current Assignment Before Partition Revocation
Pritam Kumar (Jira)
[jira] [Commented] (KAFKA-17598) Command line validation tool for RE2J regex
PoAn Yang (Jira)
[PR] KAFKA-16495 Fix flaky TransactionsWithTieredStoreTest#testCommitTransactionTimeout [kafka]
via GitHub
[jira] [Updated] (KAFKA-17591) Consumer protocol subscription regex support
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17598) Command line validation tool for RE2J regex
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17597) Update OffsetsMetadataManager to consider topics subscribed from regex
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-17495) Factor out common setup from server-side assignor benchmarks
David Jacot (Jira)
[jira] [Created] (KAFKA-17596) Benchmark regex resolution
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17595) Stored regexes refresh to reflect metadata changes
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17594) Integrate resolved regexes in assignment computation
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17593) Async regex resolution
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17592) Support for subscription regex in HB RPC
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-17591) Consumer protocol subscription regex support
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Jun Rao (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Fake (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Jun Rao (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Fake (Jira)
[jira] [Commented] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
Fake (Jira)
[jira] [Updated] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Created] (KAFKA-17590) ReplicaFetcher throw CorruptRecordException
ChenLin (Jira)
[jira] [Resolved] (KAFKA-17575) TestUtils.tempDirectory registers two shutdown hooks for the same thing
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Chia-Ping Tsai (Jira)
[PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
Re: [PR] MINOR: Bump zstd-jni from 1.5.6-5 to 1.5.6-6 [kafka]
via GitHub
[jira] [Commented] (KAFKA-16054) Sudden 100% CPU on a broker
Oleksandr Shulgin (Jira)
[jira] [Resolved] (KAFKA-16054) Sudden 100% CPU on a broker
Oleksandr Shulgin (Jira)
[PR] KAFKA-17585: `offsetResetStrategyTimestamp` should return `long` instead of `Long` [kafka]
via GitHub
Re: [PR] KAFKA-17585: `offsetResetStrategyTimestamp` should return `long` instead of `Long` [kafka]
via GitHub
Re: [PR] KAFKA-17585: `offsetResetStrategyTimestamp` should return `long` instead of `Long` [kafka]
via GitHub
Re: [PR] KAFKA-17585: `offsetResetStrategyTimestamp` should return `long` instead of `Long` [kafka]
via GitHub
[jira] [Assigned] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Arpit Goyal (Jira)
[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Arpit Goyal (Jira)
[jira] [Commented] (KAFKA-17586) AsyncKafkaConsumer#seek should NOT wait the completion of backgound
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-17528) Remove whitelist/blacklist from JMXReporter
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16619) Unnecessary controller warning : "Loaded ZK migration state of NONE"
Rohit Pandey (Jira)
[jira] [Commented] (KAFKA-7062) Simplify MirrorMaker loop after removal of old consumer support
Rohit Pandey (Jira)
[jira] [Commented] (KAFKA-17581) AsyncKafkaConsumer can't unsubscribe invalid topics
Kirk True (Jira)
[jira] [Commented] (KAFKA-17581) AsyncKafkaConsumer can't unsubscribe invalid topics
PoAn Yang (Jira)
[PR] [WIP] KAFKA-16974 Support to create a quorum controller which is not in cluster [kafka]
via GitHub
[PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
Re: [PR] KAFKA-17459: Stablize reassign_partitions_test.py [kafka]
via GitHub
[jira] [Commented] (KAFKA-17459) Stabalize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17459) Stabilize reassign_partitions_test.py
Chia-Ping Tsai (Jira)
[PR] KAFKA-17570: Rewrite StressTestLog by JMH [kafka]
via GitHub
Re: [PR] KAFKA-17570: Rewrite StressTestLog by JMH [kafka]
via GitHub
[jira] [Commented] (KAFKA-15528) KIP-986: Cross-Cluster Replication
Jiashen Zhang (Jira)
[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor
Chia-Chuan Yu (Jira)
[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-17551) Remove ForeachProcessor
Chia-Chuan Yu (Jira)
[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance
Chia-Chuan Yu (Jira)
[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17588) Remove internal classes from ClusterInstance
David Arthur (Jira)
[PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]
via GitHub
Re: [PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]
via GitHub
[PR] MINOR: validate ReplaceField config [kafka]
via GitHub
Re: [PR] MINOR: validate ReplaceField config [kafka]
via GitHub
Re: [PR] MINOR: validate ReplaceField config [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed
TengYao Chi (Jira)
[jira] [Commented] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed
TengYao Chi (Jira)
[jira] [Commented] (KAFKA-16966) Allow offset commit fetch to reuse previous request if partitions are a subset
TaiJuWu (Jira)
[PR] KAFKA-17568 Rewrite TestPurgatoryPerformance by JMH [kafka]
via GitHub
Re: [PR] MINOR: Code cleanup Kafka Streams [kafka]
via GitHub
Re: [PR] MINOR: Remove incompatible system ducktape upgrade tests [kafka]
via GitHub
Re: [PR] MINOR: Remove incompatible system ducktape upgrade tests [kafka]
via GitHub
[jira] [Commented] (KAFKA-17589) Move JUnit extensions to test-common module
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-17589) Move JUnit extensions to test-common module
David Arthur (Jira)
[jira] [Resolved] (KAFKA-17567) Remove TestTruncate
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17587) Move test infrastructure out of core
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17587) Move test infrastructure out of core
David Arthur (Jira)
[jira] [Commented] (KAFKA-17587) Move test infrastructure out of core
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-17587) Move test infrastructure out of core
David Arthur (Jira)
[jira] [Commented] (KAFKA-17587) Move test infrastructure out of core
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-17589) Move JUnit extensions to test-common module
David Arthur (Jira)
[jira] [Created] (KAFKA-17588) Remove internal classes from ClusterInstance
David Arthur (Jira)
[jira] [Created] (KAFKA-17587) Move test infrastructure out of core
David Arthur (Jira)
[jira] [Resolved] (KAFKA-16813) Add global timeout for "@Test" and "@TestTemplate"
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-16813: Add global timeout for `@ClusterTemplate`, `@ClusterTest` and `@ClusterTests` [kafka]
via GitHub
[jira] [Resolved] (KAFKA-17307) Remove junit-platform.properties from test JARs
David Arthur (Jira)
[jira] [Commented] (KAFKA-16779) Kafka retains logs past specified retention
Nicholas Feinberg (Jira)
Earlier messages