jira  

Messages by Thread

• • Re: [PR] Update README.md [kafka] via GitHub
• Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka] via GitHub
  • Re: [PR] Nilmadhab/co grouped windowed aggrgation [kafka] via GitHub
• [PR] KAFKA-20205: Refactor serialization and deserialization code for *WithHeaders types [kafka] via GitHub
  • Re: [PR] KAFKA-20205: Refactor serialization and deserialization code for *WithHeaders types [kafka] via GitHub
• [PR] fix: replace printStackTrace() with proper logging in KafkaStreamsNamedTopologyWrapper [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19655) The normal topic auto-creation paths should use num.partitions and default.replication.factor from the controller properties Luke Chen (Jira)
• Re: [PR] MINOR: Keep pendingTask as WakeupFuture if currentTask is completed already. [kafka] via GitHub
  • Re: [PR] MINOR: Keep pendingTask as WakeupFuture if currentTask is completed already. [kafka] via GitHub
• [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka] via GitHub
  • Re: [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka] via GitHub
  • [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka] via GitHub
  • Re: [PR] KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999) [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException Siddhartha Devineni (Jira)
• [jira] [Commented] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException Siddhartha Devineni (Jira)
• [jira] [Comment Edited] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Matthias J. Sax (Jira)
  • [jira] [Comment Edited] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-20211) Add new group coordinator executor metrics David Jacot (Jira)
• [PR] Kafka 20241 fix [kafka] via GitHub
  • Re: [PR] KAFKA-20241 [kafka] via GitHub
  • Re: [PR] KAFKA-20241 [kafka] via GitHub
  • Re: [PR] KAFKA-20241 [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20250) Move UnifiedLogTest to storage module Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-20250) Move UnifiedLogTest to storage module Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20250) Move UnifiedLogTest to storage module Mickael Maison (Jira)
• [PR] KAFKA-20241 [kafka] via GitHub
  • Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] via GitHub
  • Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] via GitHub
  • Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] via GitHub
  • Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] via GitHub
  • Re: [PR] KAFKA-20241: Bump jackson to 2.21.1 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Adapters Alieh Saeedi (Jira)
• [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, exam… [kafka] via GitHub
  • Re: [PR] MINOR: Update collections with Java 11 equivalents in generator, examples, and jmh-benchmarks [kafka] via GitHub
• [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20249) Optimize rawValue methods across all Deserializers Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Lucas Brutschy (Jira)
  • [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. sanghyeok An (Jira)
• [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Aleksei Veremeev (Jira)
  • [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Aleksei Veremeev (Jira)
  • [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Aleksei Veremeev (Jira)
  • [jira] [Commented] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Aleksei Veremeev (Jira)
• [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
  • Re: [PR] KAFKA-20247: Controller registration needs to retry after request timeout [kafka] via GitHub
• Re: [PR] KAFKA-19446: Add Transaction Version to request builder [2/3] [kafka] via GitHub
• [jira] [Created] (KAFKA-20247) ControllerRegistrationManager does not retry registration after timing out Kevin Wu (Jira)
• [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20078) kafka-dump-log tool should return proper exit code Chih-Yuan Chien (Jira)
• [jira] [Commented] (KAFKA-20078) kafka-dump-log tool should return proper exit code Chih-Yuan Chien (Jira)
• [jira] [Resolved] (KAFKA-20210) Add group.coordinator.executor.threads config David Jacot (Jira)
• [jira] [Comment Edited] (KAFKA-20243) TCP connection count per client.id Mahesh Sambaram (Jira)
• [jira] [Commented] (KAFKA-20243) TCP connection count per client.id Mahesh Sambaram (Jira)
• [PR] KAFKA-17895: Add num-keys metric for in-memory state stores [kafka] via GitHub
• [PR] KAFKA-20211: Add group coordinator background metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20211: Add group coordinator background metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20211: Add group coordinator background metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20211: Add group coordinator background metrics [kafka] via GitHub
• Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka] via GitHub
  • Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka] via GitHub
  • Re: [PR] KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions [kafka] via GitHub
• Re: [PR] KAFKA-19891: Suppress error-level heartbeat logs during consumer close [kafka] via GitHub
• [jira] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
• Re: [PR] MINOR: Optimize Struct.validate() field iteration [kafka] via GitHub
• Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] via GitHub
  • Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] via GitHub
  • Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] via GitHub
  • Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] via GitHub
  • Re: [PR] MINOR: Fix GroupConfigManager.validate() to include all group type defaults [kafka] via GitHub
• [jira] [Created] (KAFKA-20246) Detection and handling of misrouted connections Andrew Schofield (Jira)
• Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) [kafka] via GitHub
• [jira] [Assigned] (KAFKA-7952) Consider to switch to in-memory stores in test whenever possible Ziyun Fu (Jira)
• [jira] [Created] (KAFKA-20245) Implementation for dead-letter queues for share groups Andrew Schofield (Jira)
• [jira] [Assigned] (KAFKA-20242) Release notes links are broken in documentation Karl Sorensen (Jira)
• [jira] [Commented] (KAFKA-20242) Release notes links are broken in documentation Karl Sorensen (Jira)
  • [jira] [Commented] (KAFKA-20242) Release notes links are broken in documentation Karl Sorensen (Jira)
  • [jira] [Commented] (KAFKA-20242) Release notes links are broken in documentation ASF GitHub Bot (Jira)
• [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-20239: Document Kafka ACLS required for Connect [kafka] via GitHub
• [jira] [Created] (KAFKA-20244) Kafka 5.0.0 updates for KIP-1280 Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring Manan Gupta (Jira)
• [jira] [Created] (KAFKA-20243) TCP connection count per client.id Nebojsa Simic (Jira)
• Re: [PR] MINOR: Update jackson to 2.20.1 and jackson-annotations to 2.20 [kafka] via GitHub
  • Re: [PR] MINOR: Update jackson to 2.20.1 and jackson-annotations to 2.20 [kafka] via GitHub
  • Re: [PR] MINOR: Update jackson to 2.20.1 and jackson-annotations to 2.20 [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition Christo Lolov (Jira)
  • [jira] [Comment Edited] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition Christo Lolov (Jira)
• [jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition Christo Lolov (Jira)
• Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka] via GitHub
  • Re: [PR] KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20239) Document Kafka ACLs required for Connect workers Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-20242) Release notes links are broken in documentation Josep Prat (Jira)
• [jira] [Created] (KAFKA-20242) Release notes links are broken in documentation Anton Agestam (Jira)
• [jira] [Created] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Aleksei Veremeev (Jira)
• [jira] [Created] (KAFKA-20240) Update upgrade.md to mention new configs Sean Quah (Jira)
• [PR] MINOR: Update jackson due to CVE [kafka] via GitHub
  • Re: [PR] MINOR: Update jackson due to CVE [kafka] via GitHub
  • Re: [PR] MINOR: Update jackson due to CVE [kafka] via GitHub
  • Re: [PR] MINOR: Update jackson due to CVE [kafka] via GitHub
• Re: [PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka] via GitHub
  • Re: [PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure sanghyeok An (Jira)
• [jira] [Created] (KAFKA-20239) Document Kafka ACLs required for Connect workers Dale Lane (Jira)
• [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
• [jira] [Updated] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode mapan (Jira)
• [jira] [Created] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode mapan (Jira)
• [jira] [Commented] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics Prince Raiyani (Jira)
  • [jira] [Commented] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-14597) [Streams] record-e2e-latency-max is not reporting correct metrics Prince Raiyani (Jira)
• [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
  • [jira] [Updated] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
• [jira] [Created] (KAFKA-20237) TransactionManager stuck in `INITIALIZING` state after initial SSL handshake failure Yin Lei (Jira)
• [jira] [Resolved] (KAFKA-20204) Remove partition-level `ExpiresPerSec`metrics when the broker no longer ownsthe partition Chia-Ping Tsai (Jira)
• [PR] KAFKA-20157 documment KIP-1257 partition size percentage metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20157 Document KIP-1257 partition size percentage metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20157 Document KIP-1257 partition size percentage metrics [kafka] via GitHub
• [PR] KAFKA-20157 Add RetentionSizeInPercent metrics for regular topics [kafka] via GitHub
  • Re: [PR] KAFKA-20157 Add RetentionSizeInPercent metrics for regular topics [kafka] via GitHub
  • Re: [PR] KAFKA-20157 Add RetentionSizeInPercent metrics for regular topics [kafka] via GitHub
  • Re: [PR] KAFKA-20157 Add RetentionSizeInPercent metrics for regular topics [kafka] via GitHub
• Re: [PR] KAFKA-17178: Internal KTable#transformValues refactoring [kafka] via GitHub
• Re: [PR] Support keystore with multiple alias entries [kafka] via GitHub
• Re: [PR] KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class [kafka] via GitHub
  • Re: [PR] KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class [kafka] via GitHub
• [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka] via GitHub
  • Re: [PR] KAFKA-20211 [2/2]: Add group coordinator executor metrics [kafka] via GitHub
• [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka] via GitHub
  • Re: [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka] via GitHub
  • Re: [PR] KAFKA-20211 [1/2]: Change CoordinatorRuntime executor type from ExecutorService to ThreadPoolExecutor [kafka] via GitHub
• [jira] [Commented] (KAFKA-19939) ProductionExceptionHandler and DLQ does not support global thread Arpit Goyal (Jira)
• [jira] [Assigned] (KAFKA-9651) Divide by zero in DefaultPartitioner Tom Bentley (Jira)
  • [jira] [Assigned] (KAFKA-9651) Divide by zero in DefaultPartitioner Nilesh Kumar (Jira)
• [jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner Nilesh Kumar (Jira)
  • [jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner Nilesh Kumar (Jira)
  • [jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner Tom Bentley (Jira)
  • [jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner Nilesh Kumar (Jira)
• [PR] handling 0 partitions [kafka] via GitHub
  • Re: [PR] handling 0 partitions [kafka] via GitHub
  • Re: [PR] handling 0 partitions [kafka] via GitHub
  • Re: [PR] handling 0 partitions [kafka] via GitHub
  • Re: [PR] kAFKA-9651:handling 0 partitions [kafka] via GitHub
  • Re: [PR] kAFKA-9651:handling 0 partitions [kafka] via GitHub
  • Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka] via GitHub
  • Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka] via GitHub
  • Re: [PR] kAFKA-9651:Handle edge case when partition metadata contains zero partitions [kafka] via GitHub

• Earlier messages
• Later messages