jira  

Messages by Thread

• [jira] [Updated] (KAFKA-18139) AsyncKafkaConsumer's ConsumerNetworkThread loop requires further optimization Kirk True (Jira)
• [jira] [Updated] (KAFKA-18216) High water mark or last stable offset aren't always updated after a fetch request is completed Kirk True (Jira)
• [jira] [Updated] (KAFKA-18217) Slow HWM/LSO update might have subtle effect on the consumer lag reporting Kirk True (Jira)
• [jira] [Updated] (KAFKA-18376) High CPU load when AsyncKafkaConsumer uses a small max poll value Kirk True (Jira)
• [jira] [Updated] (KAFKA-19296) Revise AsyncKafkaConsumer event wakeup approach Kirk True (Jira)
• [jira] [Updated] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer Kirk True (Jira)
  • [jira] [Updated] (KAFKA-19259) Async consumer fetch intermittent delays on console consumer Kirk True (Jira)
• [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
  • Re: [PR] MINOR: Improve skip-record-metadata description [kafka] via GitHub
• Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
  • Re: [PR] KAFKA-16913 - Support external schemas in JSONConverter [kafka] via GitHub
• [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
  • Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka] via GitHub
• [jira] [Updated] (KAFKA-19572) Fix NPE messages in ConsoleShareConsumer. Shivsundar R (Jira)
  • [jira] [Updated] (KAFKA-19572) Fix NPE messages in ConsoleShareConsumer. Shivsundar R (Jira)
• [PR] KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline [kafka] via GitHub
  • Re: [PR] KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline [kafka] via GitHub
  • Re: [PR] KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline [kafka] via GitHub
  • Re: [PR] KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19572) Fix NPE messages in ConsoleShareConsumer. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-19572) Fix NPE messages in ConsoleShareConsumer. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Ilyas Toumlilt (Jira)
• [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
  • Re: [PR] KAFKA-19570: Implement offline migration for streams groups [kafka] via GitHub
• [jira] [Updated] (KAFKA-19570) Implement offline migration Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-19570) Implement offline migration Lucas Brutschy (Jira)
• [jira] [Updated] (KAFKA-19556) [Connect] Provide a configuration to disable SNI required and SNI host checking for the REST API Tamas Kornai (Jira)
  • [jira] [Updated] (KAFKA-19556) [Connect] Provide a configuration to disable SNI required and SNI host checking for the REST API Tamas Kornai (Jira)
• [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
  • [jira] [Updated] (KAFKA-19174) Gradle version upgrade 8 -->> 9 Jira
• Re: [PR] KAFKA-15585: DescribeTopicPartitions client side change. [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-18647) Clarifying Windows Support in the Kafka Quick Start Documentation Keng Onn Wong (Jira)
• [jira] [Commented] (KAFKA-18647) Clarifying Windows Support in the Kafka Quick Start Documentation Keng Onn Wong (Jira)
• Re: [PR] KAFKA-14604: SASL session expiration time will be overflowed when calculation [kafka] via GitHub
  • Re: [PR] KAFKA-14604: SASL session expiration time will be overflowed when calculation [kafka] via GitHub
  • Re: [PR] KAFKA-14604: SASL session expiration time will be overflowed when calculation [kafka] via GitHub
  • Re: [PR] KAFKA-14604: SASL session expiration time will be overflowed when calculation [kafka] via GitHub
• Re: [PR] KAFKA-19097: Fix assertEquals arguement order in InternalStreamsBuilderTest [kafka] via GitHub
  • Re: [PR] KAFKA-19097: Fix assertEquals arguement order in InternalStreamsBuilderTest [kafka] via GitHub
• [jira] [Reopened] (KAFKA-14604) SASL session expiration time will be overflowed when calculation dyingjiecai (Jira)
• [jira] [Resolved] (KAFKA-14604) SASL session expiration time will be overflowed when calculation dyingjiecai (Jira)
• [jira] [Commented] (KAFKA-19569) Potential Long.MAX_VALUE overflow in sessionExpirationTimeNanos calculation in SaslServerAuthenticator dyingjiecai (Jira)
• [jira] [Commented] (KAFKA-14604) SASL session expiration time will be overflowed when calculation PoAn Yang (Jira)
• [PR] KAFKA-19569: Potential Long.MAX_VALUE overflow in sessionExpirationTimeNanos calculation in SaslServerAuthenticator [kafka] via GitHub
  • Re: [PR] KAFKA-19569: Potential Long.MAX_VALUE overflow in sessionExpirationTimeNanos calculation in SaslServerAuthenticator [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19569) Potential Long.MAX_VALUE overflow in sessionExpirationTimeNanos calculation in SaslServerAuthenticator Luke Chen (Jira)
• [jira] [Created] (KAFKA-19569) Potential Long.MAX_VALUE overflow in sessionExpirationTimeNanos calculation in SaslServerAuthenticator dyingjiecai (Jira)
• [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
  • Re: [PR] KAFKA-19476: Concurrent execution fixes for lock timeout and lso movement [kafka] via GitHub
• [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
  • Re: [PR] MINOR: retry upon missing source topic [kafka] via GitHub
• [PR] KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics [kafka] via GitHub
  • Re: [PR] KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics [kafka] via GitHub
  • Re: [PR] KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics [kafka] via GitHub
• Re: [PR] KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID [kafka] via GitHub
• [PR] Improve consistency of acknowledge type terminology [kafka] via GitHub
  • Re: [PR] MINOR: Improve consistency of acknowledge type terminology [kafka] via GitHub
• [PR] MINOR: Fix javadoc mistake [kafka] via GitHub
  • Re: [PR] MINOR: Fix javadoc mistake [kafka] via GitHub
  • Re: [PR] MINOR: Fix javadoc mistake [kafka] via GitHub
  • Re: [PR] MINOR: Fix javadoc mistake [kafka] via GitHub
• [PR] Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka] via GitHub
  • Re: [PR] Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka] via GitHub
  • Re: [PR] Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method [kafka] via GitHub
  • Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method [kafka] via GitHub
• [PR] MINOR: Note KS broker replication factor limitation [kafka] via GitHub
  • Re: [PR] MINOR: Note KS broker replication factor limitation [kafka] via GitHub
  • Re: [PR] MINOR: Note KS broker replication factor limitation [kafka] via GitHub
  • Re: [PR] MINOR: Note KS broker replication factor limitation [kafka] via GitHub
• [PR] MINOR: Align order or gradle command [kafka] via GitHub
  • Re: [PR] MINOR: Align order on gradle command [kafka] via GitHub
  • Re: [PR] MINOR: Align order on gradle command [kafka] via GitHub
• [PR] MINOR: Fix typo in GetOffsetShell [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in GetOffsetShell [kafka] via GitHub
• [PR] KAFKA-19513: Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords() [kafka] via GitHub
  • Re: [PR] KAFKA-19513: Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords() [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19513) Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords() Qiang Liu (Jira)
• [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup RaftClient#upgradeKRaftVersion java document [kafka] via GitHub
• [jira] [Updated] (KAFKA-18973) Review MetadataSchemaCheckerToolTest.testVerifyEvolutionGit requiring git project Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-19524) connect-plugin-path crashes with UnsupportedOperationException on plugins without ServiceLoader manifests Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19568) Add disk usage threshold to prevent disk full failure mapan (Jira)
• [jira] [Created] (KAFKA-19568) Add disk usage threshold to prevent disk full failure mapan (Jira)
• [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
  • Re: [PR] KAFKA-19529: State updater sensor names should be unique (#20262) [kafka] via GitHub
• [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
  • Re: [PR] MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable [kafka] via GitHub
• [jira] [Commented] (KAFKA-19480) KRaft migration hangs when /migration has null value ASF GitHub Bot (Jira)
• [jira] [Resolved] (KAFKA-19563) Separate the controller config and admin config when add controller Luke Chen (Jira)
• [jira] [Created] (KAFKA-19567) Purgatory should clear up after share consumers are stopped Chirag Wadhwa (Jira)
• [jira] [Updated] (KAFKA-19287) docuemnt all group coordinator metrics Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka] via GitHub
  • Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka] via GitHub
• Re: [PR] KAFKA-18982: Allow ClusterTests to ignore specific thread leaks [kafka] via GitHub
  • Re: [PR] KAFKA-18982: Allow ClusterTests to ignore specific thread leaks [kafka] via GitHub
• Re: [PR] KAFKA-16907: Fix RaftUtil's type complexity [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19287) docuemnt all group coordinator metrics Bolin Lin (Jira)
• [jira] [Commented] (KAFKA-19021) Broker should not be allowed to be promoted to controller Jimmy Wang (Jira)
• [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub
  • Re: [PR] KAFKA-19576 Fix typo in state-change log filename after rotate [kafka] via GitHub

• Earlier messages
• Later messages