jira  

Messages by Thread

• [jira] [Commented] (KAFKA-16800) Resolve Gradle 9.0 deprecations Jira
• [jira] [Commented] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols Kirk True (Jira)
• [jira] [Commented] (KAFKA-18061) AddRaftVoter responds with error message "NONE" instead of null Chang Chi Hsu (Jira)
• [jira] [Updated] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException Kirk True (Jira)
• [jira] [Created] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException Kirk True (Jira)
• [jira] [Updated] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols Kirk True (Jira)
• [jira] [Commented] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer Kirk True (Jira)
  • [jira] [Commented] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer Arpit Goyal (Jira)
• [PR] KAFKA-19635: Minor docs tweaks [kafka] via GitHub
  • Re: [PR] KAFKA-19635: Minor docs tweaks [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19635) Update upgrade.html with the changes in Apache Kafka 4.2 Andrew Schofield (Jira)
• [PR] KAFKA-19520: Bump Commons-Lang for CVE-2025-48924 [kafka] via GitHub
  • Re: [PR] KAFKA-19520: Bump Commons-Lang for CVE-2025-48924 [kafka] via GitHub
• [PR] MINOR: Cleanup `toString` methods in Storage Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup `toString` methods in Storage Module [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup `toString` methods in Storage Module [kafka] via GitHub
• [jira] [Created] (KAFKA-19650) Add message key to org.apache.kafka.clients.producer.RecordMetadata Schubert Fernandes (Jira)
• [PR] KAFKA-19626: KIP-1147 Consistency of command-line arguments for remaining CLI tools [kafka] via GitHub
  • Re: [PR] KAFKA-19626: KIP-1147 Consistency of command-line arguments for remaining CLI tools [kafka] via GitHub
• [PR] KAFKA-16263 : Add Kafka Streams docs about available listeners/callback [kafka] via GitHub
• [PR] MINOR: Add doc for external schemas in JSONConverter [kafka] via GitHub
• [PR] [WIP] KAFKA-17302 [kafka] via GitHub
• [jira] [Created] (KAFKA-19649) Document List Offset changes in upgrade.html Abhijeet Kumar (Jira)
• [PR] MINOR: Add a missing @Test to test case [kafka] via GitHub
  • Re: [PR] MINOR: Add a missing @Test to test case [kafka] via GitHub
• Re: [PR] KAFKA-15370: Support Participation in 2PC (KIP-939) (K/N) [kafka] via GitHub
• [PR] MINOR: remove arguments from AsyncKafkaConsumerTest.newConsumer() that are identical [kafka] via GitHub
  • Re: [PR] MINOR: remove arguments from AsyncKafkaConsumerTest.newConsumer() that are identical [kafka] via GitHub
• [PR] MINOR: cleanup String.format [kafka] via GitHub
  • Re: [PR] MINOR: cleanup String.format [kafka] via GitHub
• [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
  • Re: [PR] MINOR: suppress build warning [kafka] via GitHub
• Re: [PR] MINOR: Make InternalStreamsBuilder#addGraphNode public [kafka] via GitHub
  • Re: [PR] MINOR: Make InternalStreamsBuilder#addGraphNode public [kafka] via GitHub
  • Re: [PR] MINOR: Make InternalStreamsBuilder#addGraphNode public [kafka] via GitHub
• Re: [PR] KAFKA-18053 Clean up topology config [kafka] via GitHub
  • Re: [PR] KAFKA-18053 Clean up topology config [kafka] via GitHub
• Re: [PR] KAFKA-14830: Illegal state error in transactional producer [kafka] via GitHub
• [PR] MINOR: Update Kafka Streams API broker compatibility table for 4.1 [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Jira
• [jira] [Created] (KAFKA-19648) KIP-1170: Unify cluster metadata bootstrapping Jira
• [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
  • Re: [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
  • Re: [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
  • Re: [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
  • Re: [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
  • Re: [PR] KAFKA-19467: Add a metric for controller thread idleness [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19641) Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener Lucas Brutschy (Jira)
• [PR] MINOR: Remove default config in creating internal stream topic [kafka] via GitHub
  • Re: [PR] MINOR: Remove default config in AutoTopicCreationManager#createStreamsInternalTopics [kafka] via GitHub
  • Re: [PR] MINOR: Remove default config in AutoTopicCreationManager#createStreamsInternalTopics [kafka] via GitHub
  • Re: [PR] MINOR: Remove default config in AutoTopicCreationManager#createStreamsInternalTopics [kafka] via GitHub
  • Re: [PR] MINOR: Remove default config in AutoTopicCreationManager#createStreamsInternalTopics [kafka] via GitHub
• [PR] KAFKA-19535: add integration tests for DescribeProducersOptions#brokerId [kafka] via GitHub
  • Re: [PR] KAFKA-19535: add integration tests for DescribeProducersOptions#brokerId [kafka] via GitHub
• [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
  • Re: [PR] KAFKA-19641: Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener [kafka] via GitHub
• [PR] MINOR: Remove OffsetsForLeaderEpochRequest unused static field [kafka] via GitHub
  • Re: [PR] MINOR: Remove OffsetsForLeaderEpochRequest unused static field [kafka] via GitHub
• [PR] KAFKA-19546: draft [kafka] via GitHub
• [PR] MINOR: Updated name from messages to records for consistency in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Updated name from messages to records for consistency in share partition [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19625) Consistency of command-line arguments for verifiable producer/consumer Andrew Schofield (Jira)
• [PR] KAFKA-19635: KIP-1147 changes for upgrade.html [kafka] via GitHub
  • Re: [PR] KAFKA-19635: KIP-1147 changes for upgrade.html [kafka] via GitHub
  • Re: [PR] KAFKA-19635: KIP-1147 changes for upgrade.html [kafka] via GitHub
  • Re: [PR] KAFKA-19635: KIP-1147 changes for upgrade.html [kafka] via GitHub
  • Re: [PR] KAFKA-19635: KIP-1147 changes for upgrade.html [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19632) Handle overlap batch alignment on partition reassignment Apoorv Mittal (Jira)
• [jira] [Updated] (KAFKA-19635) Update upgrade.html with the changes in Apache Kafka 4.2 Andrew Schofield (Jira)
• [PR] KAFKA-19645: add a lower bound to num.replica.fetchers [kafka] via GitHub
• Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] via GitHub
• Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka] via GitHub
  • Re: [PR] MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch [kafka] via GitHub
• [jira] [Resolved] (KAFKA-17108) Expose EarliestPendingUpload offset spec in ListOffsets API Kamal Chandraprakash (Jira)
• [jira] [Resolved] (KAFKA-18853) encourage users to use LogLevelConfig to configure dynamic logger level Chia-Ping Tsai (Jira)
• [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
  • Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
  • Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka] via GitHub
• [PR] MINOR: Add example integration test commands to README [kafka] via GitHub
  • Re: [PR] MINOR: Add example integration test commands to README [kafka] via GitHub
• [jira] [Resolved] (KAFKA-18600) Cleanup NetworkClient zk related logging Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-18600 Cleanup NetworkClient zk related logging [kafka] via GitHub
• [jira] [Updated] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch Jira
• [jira] [Updated] (KAFKA-17108) Expose EarliestPendingUpload offset spec in ListOffsets API Kamal Chandraprakash (Jira)
• [jira] [Updated] (KAFKA-15307) Kafka Streams configuration docs outdated Mickael Maison (Jira)
  • [jira] [Updated] (KAFKA-15307) Kafka Streams configuration docs outdated Mickael Maison (Jira)
• [PR] KAFKA-19647 Implement integration test for offline migration [kafka] via GitHub
  • Re: [PR] KAFKA-19647: Implement integration test for offline migration [kafka] via GitHub
  • Re: [PR] KAFKA-19647: Implement integration test for offline migration [kafka] via GitHub
  • Re: [PR] KAFKA-19647: Implement integration test for offline migration [kafka] via GitHub
  • Re: [PR] KAFKA-19647: Implement integration test for offline migration [kafka] via GitHub
  • Re: [PR] KAFKA-19647: Implement integration test for offline migration [kafka] via GitHub
• [jira] [Updated] (KAFKA-19647) Implement integration test for offline migration Lucas Brutschy (Jira)
  • [jira] [Updated] (KAFKA-19647) Implement integration test for offline migration Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-19647) Implement integration test for offline migration Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-19647) Implement integration test for offline migration Lucas Brutschy (Jira)
• [jira] [Comment Edited] (KAFKA-19613) Expose consumer CorruptRecordException as case of KafkaException Uladzislau Blok (Jira)
  • [jira] [Comment Edited] (KAFKA-19613) Expose consumer CorruptRecordException as case of KafkaException FliegenKLATSCH (Jira)
• [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
  • Re: [PR] MINOR: Refactored gap window names in share partition [kafka] via GitHub
• Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
  • Re: [PR] KAFKA-18185: remove internal.leave.group.on.close config [kafka] via GitHub
• [PR] MINOR: Optimize the entriesWithoutErrorsPerPartition when errorResults is empty [kafka] via GitHub
  • Re: [PR] MINOR: Optimize the entriesWithoutErrorsPerPartition when errorResults is empty [kafka] via GitHub
  • Re: [PR] MINOR: Optimize the entriesWithoutErrorsPerPartition when errorResults is empty [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19646) CLONE - Broker Startup: Handle Checkpoint Creation Failure via logDirFailureChannel Haozhong Ma (Jira)
• [jira] [Closed] (KAFKA-19646) CLONE - Broker Startup: Handle Checkpoint Creation Failure via logDirFailureChannel Haozhong Ma (Jira)
• [jira] [Closed] (KAFKA-19548) Broker Startup: Handle Checkpoint Creation Failure via logDirFailureChannel Haozhong Ma (Jira)
• [jira] [Resolved] (KAFKA-19548) Broker Startup: Handle Checkpoint Creation Failure via logDirFailureChannel Haozhong Ma (Jira)
• [jira] [Created] (KAFKA-19646) CLONE - Broker Startup: Handle Checkpoint Creation Failure via logDirFailureChannel Haozhong Ma (Jira)
• [jira] [Resolved] (KAFKA-17344) Add Unit tests for empty follower fetch scenarios Kamal Chandraprakash (Jira)
• [PR] KAFKA-19604: Document controller.quorum.auto.join.enable config in upgrade.html [kafka] via GitHub
  • Re: [PR] KAFKA-19604: Document controller.quorum.auto.join.enable config in upgrade.html [kafka] via GitHub
• [jira] [Updated] (KAFKA-18841) Enable to test docker image locally PoAn Yang (Jira)
• [jira] [Resolved] (KAFKA-18841) Enable to test docker image locally PoAn Yang (Jira)
• [jira] [Commented] (KAFKA-19622) Limitations of KRAFT Dual Write Mode for Production Support Sharad Garg (Jira)
• [jira] [Assigned] (KAFKA-19645) add a lower bound to num.replica.fetchers Lan Ding (Jira)
• Re: [PR] KAFKA-18841: Enable to test docker image locally [kafka] via GitHub
• [jira] [Commented] (KAFKA-19641) Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-19641) Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-19641) Fix flaky RestoreIntegrationTest#shouldInvokeUserDefinedGlobalStateRestoreListener Matthias J. Sax (Jira)
• [PR] MINOR: renamed testAsyncConsumerClassicConsumerSubscribeInvalidTopicC anUnsubscribe to testAsyncConsumerSubscribeInvalidTopicCanUnsubscribe [kafka] via GitHub
  • Re: [PR] MINOR: renamed testAsyncConsumerClassicConsumerSubscribeInvalidTopicCanUnsubscribe to align test case [kafka] via GitHub
• [jira] [Created] (KAFKA-19645) add a lower bound to num.replica.fetchers Chia-Ping Tsai (Jira)
• [PR] KAFKA-8080: Remove system test [kafka] via GitHub
• [jira] [Assigned] (KAFKA-8080) Remove streams_eos_test system test travis (Jira)
• Re: [PR] KAFKA-19070:: Adding task number to user provided client id to ensure each consumer has a unique client ID to avoid metric registration conflicts. [kafka] via GitHub
• [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
  • Re: [PR] KAFKA-19642: Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs [kafka] via GitHub
• [jira] [Assigned] (KAFKA-12456) Log "Listeners are not identical across brokers" message at WARN/INFO instead of ERROR Kuan Po Tseng (Jira)
• [jira] [Updated] (KAFKA-12456) Log "Listeners are not identical across brokers" message at WARN/INFO instead of ERROR Kuan Po Tseng (Jira)
• [PR] KAFKA-12456: Log 'Listeners are not identical across brokers' message at INFO instead of ERROR [kafka] via GitHub
  • Re: [PR] KAFKA-12456: Log 'Listeners are not identical across brokers' message at INFO instead of ERROR [kafka] via GitHub
• Re: [PR] KAFKA-19490: Remove usages of distutils in docker scripts [kafka] via GitHub
• [PR] KAFKA-19638: Set dummy ProcessorRecordContext for processor init [kafka] via GitHub
  • Re: [PR] KAFKA-19638: Set dummy ProcessorRecordContext for processor init [kafka] via GitHub
• [jira] [Commented] (KAFKA-19644) Enhance the documentation for producer headers Jhen-Yung Hsu (Jira)
• [jira] [Assigned] (KAFKA-19644) Enhance the documentation for producer headers Jhen-Yung Hsu (Jira)
• [jira] [Created] (KAFKA-19644) Enhance the documentation for producer headers Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
  • [jira] [Updated] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
• [jira] [Created] (KAFKA-19643) Controller keeps switching and occasionally goes offline. zzshine (Jira)
• Re: [PR] MINOR: Cleanups in Connect [kafka] via GitHub
• [PR] Add support to set the target timezone when we use the TimestampConverter. [kafka] via GitHub
• [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
  • Re: [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
  • Re: [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
  • Re: [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
  • Re: [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
  • Re: [PR] MINOR: update kraft dynamic voter set doc [kafka] via GitHub
• Re: [PR] KAFKA-7516: Attempt to dynamically load ManagementFactory [kafka] via GitHub
  • Re: [PR] KAFKA-7516: Attempt to dynamically load ManagementFactory [kafka] via GitHub
• Re: [PR] Kafka 18913/cleanup state updater on failure [kafka] via GitHub

• Earlier messages