jira  

Messages by Thread

• • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [2/N] [kafka] via GitHub
• [jira] [Commented] (KAFKA-8180) Deleting large number of topics can block the controller for the time it takes to delete all of them James Cheng (Jira)
• [jira] [Updated] (KAFKA-8180) Deleting large number of topics can block the controller for the time it takes to delete all of them James Cheng (Jira)
• [jira] [Resolved] (KAFKA-8180) Deleting large number of topics can block the controller for the time it takes to delete all of them James Cheng (Jira)
• Re: [PR] KAFKA-16799: Reduce log level for 'Node is not ready' message to TRACE [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics Kirk True (Jira)
• [jira] [Assigned] (KAFKA-19543) The set of metrics returned from Consumer.metrics() changes after Consumer.close() Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols Kirk True (Jira)
• [jira] [Assigned] (KAFKA-14335) Admin.listConsumerGroups should allow filtering, pagination Kirk True (Jira)
• [jira] [Assigned] (KAFKA-19651) Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws InterruptException Kirk True (Jira)
• [jira] [Assigned] (KAFKA-14672) Producer queue time does not reflect batches expired in the accumulator Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18571) Investigate the use of metadata caching to improve fetch request generation performance Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18574) Quarantined test list should be sorted Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18139) AsyncKafkaConsumer's ConsumerNetworkThread loop requires further optimization Kirk True (Jira)
• [jira] [Assigned] (KAFKA-18951) Validate client code and documentation in examples/ directory Kirk True (Jira)
• [jira] [Assigned] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found Kirk True (Jira)
• [jira] [Assigned] (KAFKA-19308) Improve OAuth unit testing based on code coverage analysis Kirk True (Jira)
• [jira] [Assigned] (KAFKA-15640) Refactor CompletedFetch initialization Kirk True (Jira)
• [jira] [Assigned] (KAFKA-17823) Refactor GroupRebalanceConfig to remove unused configuration Kirk True (Jira)
• [jira] [Assigned] (KAFKA-15641) Investigate CompletedFetch handleInitializeErrors for accuracy Kirk True (Jira)
• [jira] [Assigned] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol Kirk True (Jira)
  • [jira] [Assigned] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol David Jacot (Jira)
  • [jira] [Assigned] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol Shekhar Prasad Rajak (Jira)
  • [jira] [Assigned] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol David Jacot (Jira)
• [jira] [Commented] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol Kirk True (Jira)
  • [jira] [Commented] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19665) Remove waiting for event completion in AsyncKafkaConsumer.pollForRecords() Kirk True (Jira)
• [jira] [Assigned] (KAFKA-16600) Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close Kirk True (Jira)
• [jira] [Created] (KAFKA-20213) Review assignment updates in ShareConsumer from background reconciliations Lianet Magrans (Jira)
• [PR] KAKFA-1251: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
  • Re: [PR] KAKFA-20066: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [1/N] [kafka] via GitHub
• [PR] KAFKA-8416: Clarify two-step requirement for enabling Streams topology optimizations [kafka] via GitHub
  • Re: [PR] KAFKA-8416: Clarify two-step requirement for enabling Streams topology optimizations [kafka] via GitHub
  • Re: [PR] KAFKA-8416: Clarify two-step requirement for enabling Streams topology optimizations [kafka] via GitHub
  • Re: [PR] KAFKA-8416: Clarify two-step requirement for enabling Streams topology optimizations [kafka] via GitHub
• [jira] [Updated] (KAFKA-17281) Remove old PAPI methods Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-17281) Remove old PAPI methods Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-17281) Remove old PAPI methods Matthias J. Sax (Jira)
• [PR] KAFKA-20210: Add group.coordinator.executor.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.executor.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.executor.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.executor.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.executor.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
  • Re: [PR] KAFKA-20210: Add group.coordinator.background.threads config [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20212) Add offset management support to RocksDBStore Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-20212) Add offset management support to RocksDBStore Nicholas Telford (Jira)
• [jira] [Assigned] (KAFKA-19713) Auto migrate .position offsets Bill Bejeck (Jira)
• [PR] KAFKA-19709: Add LegacyCheckpointingStateStore [kafka] via GitHub
  • Re: [PR] KAFKA-19709: Add LegacyCheckpointingStateStore [kafka] via GitHub
  • Re: [PR] KAFKA-19709: Add LegacyCheckpointingStateStore [kafka] via GitHub
• [jira] [Created] (KAFKA-20211) Add new group coordinator executor metrics Sean Quah (Jira)
• [jira] [Created] (KAFKA-20210) Add group.coordinator.executor.threads config Sean Quah (Jira)
• [PR] KAFKA 19709 [kafka] via GitHub
  • Re: [PR] KAFKA 19709 [kafka] via GitHub
  • [PR] KAFKA 19709 [kafka] via GitHub
  • Re: [PR] KAFKA 19709 [kafka] via GitHub
• [jira] [Created] (KAFKA-20209) KIP-1263 Group Coordinator Assignment Batching and Offload Sean Quah (Jira)
• [PR] MINOR: Fix Streams DLQ config typo in upgrade guide [kafka] via GitHub
  • Re: [PR] MINOR: Fix Streams DLQ config typo in upgrade guide [kafka] via GitHub
  • Re: [PR] MINOR: Fix Streams DLQ config typo in upgrade guide [kafka] via GitHub
• [PR] KAFKA-19655: The normal topic auto-creation paths should use num.partitions and default.replication.factor from the controller properties [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
  • Re: [PR] KAFKA-19655: Align the behavior of num.partitions and default.replication.factor for topic creation [kafka] via GitHub
• [PR] MINOR: Add 4.2.0 to system tests [kafka] via GitHub
  • Re: [PR] MINOR: Add 4.2.0 to system tests [kafka] via GitHub
  • Re: [PR] MINOR: Add 4.2.0 to system tests [kafka] via GitHub
  • Re: [PR] MINOR: Add 4.2.0 to system tests [kafka] via GitHub
• [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] KAFKA-15853: Move static methods and SocketServer configs to AbstractKafkaConfig [kafka] via GitHub
• [PR] Add MetaProperties V2 [kafka] via GitHub
  • Re: [PR] Add MetaProperties V2 [kafka] via GitHub
  • Re: [PR] Add MetaProperties V2 [kafka] via GitHub
• [jira] [Updated] (KAFKA-20207) Handle the new ClusterIdRecord Kevin Wu (Jira)
  • [jira] [Updated] (KAFKA-20207) Handle the new ClusterIdRecord Kevin Wu (Jira)
• [PR] KAFKA-8504: Add warning about grace period required for suppress() with untilWindowCloses [kafka] via GitHub
  • Re: [PR] KAFKA-8504: Add warning about grace period required for suppress() with untilWindowCloses [kafka] via GitHub
• [jira] [Created] (KAFKA-20208) Support updating meta.properties when discovering the ClusterIdRecord Kevin Wu (Jira)
• [jira] [Created] (KAFKA-20207) Handle the new ClusterIdRecord Kevin Wu (Jira)
• [PR] test [kafka] via GitHub
  • Re: [PR] test [kafka] via GitHub
• [jira] [Commented] (KAFKA-20206) [CVE-2026-1225] [logback-core] [1.5.15] | Kafka Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-20206) [CVE-2026-1225] [logback-core] [1.5.15] | Kafka Krishna Chidrawar (Jira)
• [jira] [Created] (KAFKA-20206) [CVE-2026-1225] [logback-core] [1.5.15] | Kafka Krishna Chidrawar (Jira)
• Re: [PR] MINOR: Backport fix for test_fencing_static_consumer system test to 3.9 [kafka] via GitHub
• Re: [PR] Support DynamicListenerConfig on controller [kafka] via GitHub
  • Re: [PR] Support DynamicListenerConfig on controller [kafka] via GitHub
• Re: [PR] Add support to set the target timezone when we use the TimestampConverter. [kafka] via GitHub
• Re: [PR] KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka [kafka] via GitHub
  • Re: [PR] KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka [kafka] via GitHub
• Re: [PR] KAFKA-17651: Implement `describeUserScramCredentials` [kafka] via GitHub
  • Re: [PR] KAFKA-17651: Implement `describeUserScramCredentials` [kafka] via GitHub
• Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
  • Re: [PR] KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields [kafka] via GitHub
• [jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group sanghyeok An (Jira)
  • [jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group Lucas Brutschy (Jira)
  • [jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group sanghyeok An (Jira)
• [PR] Update Quickstart link to point to GitHub [kafka] via GitHub
  • Re: [PR] Update Quickstart link to point to GitHub [kafka] via GitHub
• [jira] [Commented] (KAFKA-20056) Allow to Store Record Headers in State Stores Guang Zhao (Jira)
  • [jira] [Commented] (KAFKA-20056) Allow to Store Record Headers in State Stores Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-14615) Use sizeCompare(Iterable[_]) to compare two iterables Andrew Holzbach (Jira)
• [PR] KAFKA-14615: Use sizeCompare for collection size equality checks [kafka] via GitHub
  • Re: [PR] KAFKA-14615: Use sizeCompare for collection size equality checks [kafka] via GitHub
• [jira] [Assigned] (KAFKA-14615) Use sizeCompare(Iterable[_]) to compare two iterables Andrew Holzbach (Jira)
  • [jira] [Assigned] (KAFKA-14615) Use sizeCompare(Iterable[_]) to compare two iterables Andrew Holzbach (Jira)
• [jira] [Resolved] (KAFKA-19915) Move HostedPartition, LogAppendResult and LogDeleteRecordsResult to server module Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types TengYao Chi (Jira)
• [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization logic for *WithHeaders types Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20205) Refactor serialization and deserialization logic for *WithHeaders types Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20205) Refactor serialization and deserialization logic for *WithHeaders types Alieh Saeedi (Jira)
• [PR] MINOR: Fix typo 'propogation' to 'propagation' in TopicCommandTest [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo 'propogation' to 'propagation' in TopicCommandTest [kafka] via GitHub
  • Re: [PR] MINOR: Fix typo 'propogation' to 'propagation' in TopicCommandTest [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20204) Remove partition-level `ExpiresPerSec`metrics when the broker no longer ownsthe partition Lan Ding (Jira)
• [jira] [Created] (KAFKA-20204) Remove partition-level `ExpiresPerSec`metrics when the broker no longer ownsthe partition Chia-Ping Tsai (Jira)
• [jira] [Commented] (KAFKA-17967) Dynamic change ProducerStateEntry#NUM_BATCHES_TO_RETAIN based on max.in.flight.requests.per.connection PoAn Yang (Jira)
• [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
  • Re: [PR] MINOR: Add 3.9.2 to system test [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20146) Add CI job to detect dependency conflicts in setup.py Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-19469) Dead-letter queues for share groups Andrew Schofield (Jira)
• [PR] MINOR: fix null overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] MINOR: fix null overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] MINOR: fix overwrite in recursive parent-node matching [kafka] via GitHub
• [PR] KAFKA-20193: Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed [kafka] via GitHub
  • Re: [PR] KAFKA-20193: Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed [kafka] via GitHub
• [jira] [Commented] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed Nishant Kumar (Jira)
  • [jira] [Commented] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders Nishant Kumar (Jira)
• [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
  • Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
  • Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
  • Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
  • Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
  • Re: [PR] MINOR: add test cases for dumpLogSegments [kafka] via GitHub
• Re: [PR] KAFKA-19890: Fix stop command failure after wmic removal in newer Windows. [kafka] via GitHub
  • Re: [PR] KAFKA-19890: Fix stop command failure after wmic removal in newer Windows. [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode M Paget (Jira)
• [jira] [Comment Edited] (KAFKA-20090) TV2 can allow for ongoing transactions with max epoch that never complete sanghyeok An (Jira)
  • [jira] [Comment Edited] (KAFKA-20090) TV2 can allow for ongoing transactions with max epoch that never complete sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-19096) Skipped Records in FK join should not be marked as dropped Matthias J. Sax (Jira)
• Re: [PR] KAFKA-19096: Added checks for the number of dropped records to foreign key join tests. [kafka] via GitHub
• [PR] MINOR: Clean up checkstyle configuration [kafka] via GitHub
  • Re: [PR] MINOR: Clean up checkstyle configuration [kafka] via GitHub
  • Re: [PR] MINOR: Clean up checkstyle configuration [kafka] via GitHub

• Earlier messages
• Later messages