jira  

Messages by Thread

• [jira] [Resolved] (KAFKA-19638) NPE in `Processor#init()` accessing state store PoAn Yang (Jira)
• [jira] [Updated] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods Aditya Kousik (Jira)
• [jira] [Assigned] (KAFKA-20386) SerDe and Interceptor Metrics Francis Godinho (Jira)
• [jira] [Commented] (KAFKA-20386) SerDe and Interceptor Metrics Francis Godinho (Jira)
  • [jira] [Commented] (KAFKA-20386) SerDe and Interceptor Metrics Aditya Kousik (Jira)
• [jira] [Commented] (KAFKA-20401) Remove deprecated ClientQuotaCallback#updateClusterMetadata Francis Godinho (Jira)
  • [jira] [Commented] (KAFKA-20401) Remove deprecated ClientQuotaCallback#updateClusterMetadata Kuan Po Tseng (Jira)
• [jira] [Commented] (KAFKA-20397) Review to improve metadata error check before blocking on buffer data in consumer Nilesh Kumar (Jira)
• [jira] [Updated] (KAFKA-20403) InterruptedException swallowed without restoring thread interrupt flag in multiple classes Muralidhar Basani (Jira)
  • [jira] [Updated] (KAFKA-20403) InterruptedException swallowed without restoring thread interrupt flag in multiple classes Mickael Maison (Jira)
• [jira] [Comment Edited] (KAFKA-18239) Passing `Cluster` to ClientQuotaCallback#updateClusterMetadata is too expensive Kuan Po Tseng (Jira)
• [jira] [Commented] (KAFKA-18239) Passing `Cluster` to ClientQuotaCallback#updateClusterMetadata is too expensive Kuan Po Tseng (Jira)
• [jira] [Created] (KAFKA-20403) Streams: InterruptedException swallowed without restoring thread interrupt flag in multiple classes Muralidhar Basani (Jira)
• [jira] [Comment Edited] (KAFKA-20397) Review to improve metadata error check before blocking on buffer data in consumer Nilesh Kumar (Jira)
• [jira] [Commented] (KAFKA-16129) Add integration test for KIP-977 Jonny Vu Huy Mai (Jira)
• [PR] KAFKA-20403 : Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
  • Re: [PR] KAFKA-20403 : streams - Fix stream threads interruptions [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-16129) Add integration test for KIP-977 Jonny Vu Huy Mai (Jira)
  • [jira] [Comment Edited] (KAFKA-16129) Add integration test for KIP-977 Jonny Vu Huy Mai (Jira)
• [jira] [Commented] (KAFKA-17337) ConsumerConfig should default to CONSUMER for group.protocol Deep Golani (Jira)
• [jira] [Updated] (KAFKA-20403) streams - interruptedException swallowed without restoring thread interrupt flag in multiple classes Muralidhar Basani (Jira)
  • [jira] [Updated] (KAFKA-20403) streams - interruptedException swallowed without restoring thread interrupt flag in multiple classes Muralidhar Basani (Jira)
• [jira] [Resolved] (KAFKA-19122) updateClusterMetadata receives multiples PartitionInfo Kuan Po Tseng (Jira)
• [jira] [Resolved] (KAFKA-18239) Passing `Cluster` to ClientQuotaCallback#updateClusterMetadata is too expensive Kuan Po Tseng (Jira)
• [jira] [Commented] (KAFKA-19122) updateClusterMetadata receives multiples PartitionInfo Kuan Po Tseng (Jira)
• [PR] KAFKA-20173: Propagate headers into serde 9/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 9/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 9/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 9/N [kafka] via GitHub
• [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20372: Fix flaky test in NamedTopologyIntegrationTest [kafka] via GitHub
• [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Propagate headers into serde 8/N [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20375) Unify method signature for retrieving config names across config classes Chia-Ping Tsai (Jira)
• [jira] [Commented] (KAFKA-20375) Unify method signature for retrieving config names across config classes Chia-Ping Tsai (Jira)
• [jira] [Commented] (KAFKA-19401) Consider keeping/removing the internal wrappers from streams module Muralidhar Basani (Jira)
  • [jira] [Commented] (KAFKA-19401) Consider keeping/removing the internal wrappers from streams module Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-19401) Consider keeping/removing the internal wrappers from streams module Muralidhar Basani (Jira)
• [PR] KAFKA-20366: Add syntax highlighting across docs (security and streams) [kafka] via GitHub
  • Re: [PR] KAFKA-20366: Add syntax highlighting across docs (security and streams) [kafka] via GitHub
  • Re: [PR] KAFKA-20366: Add syntax highlighting across docs (security and streams) [kafka] via GitHub
• [PR] MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders [kafka] via GitHub
  • Re: [PR] MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders [kafka] via GitHub
  • Re: [PR] MINOR: Simplify inheritance for MeteredTimestampedWindowStoreWithHeaders [kafka] via GitHub
• [jira] [Commented] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists() Muralidhar Basani (Jira)
• [jira] [Assigned] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists() Muralidhar Basani (Jira)
• [PR] KAFKA-19483 : Fix resource leak, cleanup [kafka] via GitHub
  • Re: [PR] KAFKA-19483 : storage : Fix resource leak, cleanup [kafka] via GitHub
  • Re: [PR] KAFKA-19483 : storage : Fix resource leak, cleanup [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19686) Trigger Docker image builds in release script Muralidhar Basani (Jira)
• [PR] KAFKA-19686 : Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
  • Re: [PR] KAFKA-19686 : release - Trigger docker builds with rc and release [kafka] via GitHub
• [jira] [Commented] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky Muralidhar Basani (Jira)
  • [jira] [Commented] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky Kirk True (Jira)
• [jira] [Assigned] (KAFKA-19780) Create a CI to verify all gradle tasks Muralidhar Basani (Jira)
• [jira] [Commented] (KAFKA-19780) Create a CI to verify all gradle tasks Muralidhar Basani (Jira)
• [jira] [Assigned] (KAFKA-18187) Replicas that receive EndQuorum should grant preVotes in that epoch Chu Cheng Li (Jira)
• [jira] [Assigned] (KAFKA-18389) Do not lose votedKey on transition to LeaderState Chu Cheng Li (Jira)
• [jira] [Assigned] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads. Chu Cheng Li (Jira)
• [jira] [Assigned] (KAFKA-18584) Fix controller restart test under KRaft_Combined mode in ClusterTestExtensionsTest Chu Cheng Li (Jira)
• [jira] [Assigned] (KAFKA-17339) LocalLogManager should support RaftClient#schedulePreparedAppend Chu Cheng Li (Jira)
  • [jira] [Assigned] (KAFKA-17339) LocalLogManager should support RaftClient#schedulePreparedAppend TaiJuWu (Jira)
• [jira] [Assigned] (KAFKA-18439) Add invariant to Raft simulation test for prevote Chu Cheng Li (Jira)
  • [jira] [Assigned] (KAFKA-18439) Add invariant to Raft simulation test for prevote TaiJuWu (Jira)
• [jira] [Assigned] (KAFKA-20044) Fix ReconfigurableQuorumIntegrationTest.testRemoveAndAddSameController Muralidhar Basani (Jira)
• [PR] KAFKA-20044 : Fix timeout ReconfigurableQuorumIntegrationTest.java [kafka] via GitHub
  • Re: [PR] KAFKA-20044 : server - Fix timeout ReconfigurableQuorumIntegrationTest.java [kafka] via GitHub
  • Re: [PR] KAFKA-20044 : server - Fix timeout ReconfigurableQuorumIntegrationTest.java [kafka] via GitHub
• [PR] KAFKA-20402: Support broker-side consumer group rebalance callback (KIP-1314) [kafka] via GitHub
  • Re: [PR] KAFKA-20402: Support broker-side consumer group rebalance callback (KIP-1314) [kafka] via GitHub
• [jira] [Created] (KAFKA-20402) KIP-1314: Support broker-side consumer group rebalance callback fujian (Jira)
• [jira] [Assigned] (KAFKA-20402) KIP-1314: Support broker-side consumer group rebalance callback fujian (Jira)
• [PR] Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka] via GitHub
• [PR] KAFKA-20089 : Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : core - Change error code to leader not avaialble while topic being created [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : clients - update javadocs -- while topic being created in background [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : clients - update javadocs -- while topic being created in background [kafka] via GitHub
  • Re: [PR] KAFKA-20089 : clients - update javadocs -- while topic being created in background [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20089) AutoTopicCreationManager should return LEADER_NOT_AVAILABLE for in-flight topic creation in KRaft Muralidhar Basani (Jira)
• [jira] [Resolved] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - ServerAndProtocol (3/N) [kafka] via GitHub
• Re: [PR] MINOR: UnifiedLog topic-partition as attribute as it is stable [kafka] via GitHub
  • Re: [PR] MINOR: UnifiedLog topic-partition as attribute as it is stable [kafka] via GitHub
• Re: [PR] KAFKA-19925: Fix transaction timeout handling during broker upgrades [kafka] via GitHub
• Re: [PR] KAFKA-20176: Add MetaProperties V2 [kafka] via GitHub
• [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Shekhar Prasad Rajak (Jira)
• [jira] [Assigned] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Shekhar Prasad Rajak (Jira)
• [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
  • Re: [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
  • Re: [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
  • Re: [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
  • Re: [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
  • Re: [PR] KAFKA-19566: Deprecate ClientQuotaCallback#updateClusterMetadata [kafka] via GitHub
• [jira] [Created] (KAFKA-20401) Remove deprecated ClientQuotaCallback#updateClusterMetadata Kuan Po Tseng (Jira)
• [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
  • Re: [PR] KAFKA-20173: Ensure Metered session-stores pass headers correctly [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20344) upgrade jetty to 12.0.34 PoAn Yang (Jira)
• [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders PoAn Yang (Jira)
  • [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Alieh Saeedi (Jira)
• [PR] Apply LinkedIn patches to Apache Kafka 3.6.0 — ZK→KRaft path [kafka] via GitHub
  • Re: [PR] Apply LinkedIn patches to Apache Kafka 3.6.0 — ZK→KRaft path [kafka] via GitHub
• [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
  • Re: [PR] KAFKA-20194: Add sesssion-header-store support to TDD [kafka] via GitHub
• [jira] [Created] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20398) Memory leak when stream threads are replaced Brandon Barron (Jira)
• [jira] [Updated] (KAFKA-20398) Memory leak when stream threads are replaced Brandon Barron (Jira)
  • [jira] [Updated] (KAFKA-20398) Memory leak when stream threads are replaced Brandon Barron (Jira)
  • [jira] [Updated] (KAFKA-20398) Memory leak when stream threads are replaced Brandon Barron (Jira)
  • [jira] [Updated] (KAFKA-20398) Memory leak when stream threads are replaced Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20398) Memory leak when stream threads are replaced Lucas Brutschy (Jira)

• Earlier messages
• Later messages