jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[PR] KAFKA-19915: [2/3] Move LogDeleteRecordsResult to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [3/3] Move LogDeleteRecordsResult to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [3/3] Move LogDeleteRecordsResult to server module [kafka]
via GitHub
[PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
[PR] [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
Re: [PR] KAFKA-19915: [2/3] Move HostedPartition to server module [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-20131) SubscriptionState endOffsetRequested remains permanently set if LIST_OFFSETS call fails
Viktor Somogyi-Vass (Jira)
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Created] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
[jira] [Created] (KAFKA-20184) jose4j marked as compileOnly in clients module causes ClassNotFoundException at runtime for OAuth authentication
Christian Semaan (Jira)
[jira] [Assigned] (KAFKA-20169) Support static membership for Kafka Streams with the streams rebalance protocol
sanghyeok An (Jira)
[PR] Corrected the stdout parsing in ShareConsumerPerformanceService [kafka]
via GitHub
Re: [PR] MINOR : Corrected the stdout parsing in ShareConsumerPerformanceService [kafka]
via GitHub
[PR] KAFKA-20146: Add CI check to detect Python dependency conflicts [kafka]
via GitHub
Re: [PR] KAFKA-20146: Add CI check to detect Python dependency conflicts [kafka]
via GitHub
Re: [PR] KAFKA-20146: Add CI check to detect Python dependency conflicts [kafka]
via GitHub
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Luke Chen (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Christo Lolov (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
[PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
Re: [PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub
[jira] [Created] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20177) Handle malformed partition.metadata without NullPointerException
Abdgali Yerkingaliyev (Jira)
[PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka]
via GitHub
Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka]
via GitHub
[PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch [kafka]
via GitHub
Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka]
via GitHub
Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka]
via GitHub
Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka]
via GitHub
Re: [PR] KAFKA-14579: Move DumpLogSegments to tools [kafka]
via GitHub
[jira] [Commented] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring
Manan Gupta (Jira)
[PR] Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
Re: [PR] Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
Re: [PR] KAFKA-20157 Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
Re: [PR] KAFKA-20157 Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
Re: [PR] KAFKA-20157 Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
Re: [PR] KAFKA-20157 Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring [kafka]
via GitHub
[PR] KAFKA-20037: Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
Re: [PR] KAFKA-20161 Group configuration for share.renew.acknowledge.enable [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20182) Upgrade gradle to 9.3.x
Ming-Yen Chung (Jira)
[jira] [Created] (KAFKA-20182) Upgrade gradle to 9.3.x
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
Re: [PR] MINOR: Move the ELR enabled check to the PartitionChangeBuilder constructor [kafka]
via GitHub
Re: [PR] KAFKA-17747: [2/N] Add compute topic and group hash [kafka]
via GitHub
[jira] [Created] (KAFKA-20180) Add last-applied-record-latency metric for brokers
Kevin Wu (Jira)
[jira] [Updated] (KAFKA-20179) Avoiding headers deserialization while changelogging
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20179) Avoiding headers deserialization while changelogging
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20179) Avoiding headers deserialization while changelogging
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20179) Avoiding headers deserialization while changelogging
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20179) Changelog optimization
Alieh Saeedi (Jira)
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (1/N) [kafka]
via GitHub
[PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
Re: [PR] KAFKA-20165: Handle retriable partition errors gracefully on OffsetFetch [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Viktor Somogyi-Vass (Jira)
[jira] [Commented] (KAFKA-20131) SubscriptionState endOffsetRequested remains permanently set if LIST_OFFSETS call fails
Viktor Somogyi-Vass (Jira)
[jira] [Commented] (KAFKA-20131) SubscriptionState endOffsetRequested remains permanently set if LIST_OFFSETS call fails
Viktor Somogyi-Vass (Jira)
[jira] [Assigned] (KAFKA-15828) Protect clients from broker hostname reuse
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-20178) Move LogCleanerIntegrationTest to storage module
Maros Orsak (Jira)
[jira] [Resolved] (KAFKA-20130) Move RecordValidationStats to storage module
Chia-Ping Tsai (Jira)
[jira] [Comment Edited] (KAFKA-20177) Handle malformed partition.metadata without NullPointerException
Abdgali Yerkingaliyev (Jira)
[PR] KAFKA-20177, Handle malformed partition.metadata without NPE [kafka]
via GitHub
Re: [PR] KAFKA-20177, Handle malformed partition.metadata without NPE [kafka]
via GitHub
Re: [PR] KAFKA-20177, Handle malformed partition.metadata without NPE [kafka]
via GitHub
[PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 (4.2) [kafka]
via GitHub
Re: [PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 (4.0) [kafka]
via GitHub
Re: [PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 (4.0) [kafka]
via GitHub
[PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 (4.1) [kafka]
via GitHub
Re: [PR] KAFKA-20168: Upgrade Jetty from 12.0.22 to 12.0.32 to fix CVE-2025-5115 (4.1) [kafka]
via GitHub
[jira] [Created] (KAFKA-20177) Handle malformed partition.metadata without NullPointerException
Abdgali Yerkingaliyev (Jira)
[jira] [Updated] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20168) Upgrade jetty to fix CVE-2025-5115
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20110) Fix generated doc and Javadoc for dynamic configs
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-20110) Fix generated doc and Javadoc for dynamic configs
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19853: commit open tasks before handling assignment [kafka]
via GitHub
[PR] MINOR: Fix documents in Getting Started [kafka]
via GitHub
Re: [PR] MINOR: Fix documents in Getting Started [kafka]
via GitHub
Re: [PR] MINOR: Fix documents in Getting Started [kafka]
via GitHub
Re: [PR] MINOR: Fix documents in Getting Started [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20126) Add javadoc to public APIs
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Kirk True (Jira)
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20101) Support org.apache.kafka.sasl.oauthbearer.allowed.urls=*
Kirk True (Jira)
[jira] [Updated] (KAFKA-20101) Support org.apache.kafka.sasl.oauthbearer.allowed.urls=*
Kirk True (Jira)
[jira] [Updated] (KAFKA-20135) Add javadoc to org.apache.kafka.clients.admin module
Kirk True (Jira)
[jira] [Updated] (KAFKA-20136) Add javadoc to org.apache.kafka.clients.consumer module
Kirk True (Jira)
[jira] [Updated] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Kirk True (Jira)
[jira] [Updated] (KAFKA-20154) Migrate Kakfa - client and non-client modules to Java 21(JDK 21)
Kirk True (Jira)
[PR] MINOR: cleanup build warnings [kafka]
via GitHub
Re: [PR] MINOR: cleanup build warnings [kafka]
via GitHub
Re: [PR] MINOR: cleanup build warnings [kafka]
via GitHub
[jira] [Commented] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly
Uladzislau Blok (Jira)
[jira] [Assigned] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly
Uladzislau Blok (Jira)
[PR] MINOR: Unwrap exceptions in CoordinatorTimerImpl and CoordinatorExecutorImpl [kafka]
via GitHub
Re: [PR] MINOR: Unwrap exceptions in CoordinatorTimerImpl and CoordinatorExecutorImpl [kafka]
via GitHub
Re: [PR] MINOR: Unwrap exceptions in CoordinatorTimerImpl and CoordinatorExecutorImpl [kafka]
via GitHub
Re: [PR] MINOR: Unwrap exceptions in CoordinatorTimerImpl and CoordinatorExecutorImpl [kafka]
via GitHub
Earlier messages
Later messages