jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka]
via GitHub
[PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
Re: [PR] KAFKA-16517 Do not decode metadata records in the internal kraft partition listener [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20650) In combined mode, BrokerServer and ControllerServer each independently called QuotaFactory.instantiate(), which created a separate ClientQuotaCallback instance via reflection for each role.
Vismay (Jira)
[jira] [Commented] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
Alan Lau (Jira)
[jira] [Created] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore
Jess Jin (Jira)
Re: [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka]
via GitHub
[jira] [Commented] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator
dino2895 (Jira)
[jira] [Updated] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-20794) Add documentation and tests for the RPC deprecatedVersions field
majialong (Jira)
[jira] [Commented] (KAFKA-20179) Avoiding headers deserialization while changelogging
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-20179) Avoiding headers deserialization while changelogging
Muralidhar Basani (Jira)
[jira] [Assigned] (KAFKA-20179) Avoiding headers deserialization while changelogging
Alieh Saeedi (Jira)
[jira] [Resolved] (KAFKA-20451) Move RequestChannel Responses to server module
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20794) Add documentation and tests for the RPC deprecatedVersions field
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
Re: [PR] KAFKA-19663: Unify kafka-broker-api-versions tool to cluster-tool and support bootstrap controllers [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20746) NPE in MetadataCache#toCluster
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
Re: [PR] KAFKA-20413: Make Streams suppress headers-aware [kafka]
via GitHub
[jira] [Resolved] (KAFKA-15545) Update Request metrics in ops.html to reflect all the APIs
Mickael Maison (Jira)
[PR] KAFKA-20783: Completion handling and more tests (3/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Completion handling and more tests (3/N) [kafka]
via GitHub
[PR] KAFKA-20793: Bump latest production ShareVersion to 2 (SV_2). [kafka]
via GitHub
Re: [PR] KAFKA-20793: Bump latest production ShareVersion to 2 (SV_2). [kafka]
via GitHub
[jira] [Created] (KAFKA-20793) Mark share.version=2 stable
Sushant Mahajan (Jira)
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
Re: [PR] KAFKA-20278 : streams - Refactor setup pattern, PART-1 [kafka]
via GitHub
[PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
Re: [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
Re: [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
Re: [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
Re: [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
Re: [PR] KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. [kafka]
via GitHub
[jira] (KAFKA-20538) Make RocksDB time-ordered buffer headers-aware
Alieh Saeedi (Jira)
[jira] [Resolved] (KAFKA-20329) Test `headers` dsl.store.format further
Alieh Saeedi (Jira)
Re: [PR] KAFKA-14249: Fix flaky TLSv1.3 idle expiry test (Tls13SelectorTest.testCloseOldestConnection) [kafka]
via GitHub
Re: [PR] KAFKA-14249: Fix flaky TLSv1.3 idle expiry test (Tls13SelectorTest.testCloseOldestConnection) [kafka]
via GitHub
Re: [PR] KAFKA-20764: Acquire tasksAndActionsLock when moving tasks between maps to avoid issues with concurrency [kafka]
via GitHub
Re: [PR] Redistribute request max bytes across remote fetch partitions in DelayedShareFetch [kafka]
via GitHub
[PR] KAFKA-20746 NPE in MetadataCache#toCluster (4.3) [kafka]
via GitHub
Re: [PR] KAFKA-20746 NPE in MetadataCache#toCluster (4.3) [kafka]
via GitHub
[PR] KAFKA-20746 NPE in MetadataCache#toCluster (#22723) [kafka]
via GitHub
Re: [PR] KAFKA-20746 NPE in MetadataCache#toCluster (4.2) [kafka]
via GitHub
[jira] [Updated] (KAFKA-20706) Implement query type 4 (TimestampedWindowRangeWithHeadersQuery)
Jess Jin (Jira)
[jira] [Updated] (KAFKA-20704) Implement query type 2 (TimestampedRangeWithHeadersQuery)
Jess Jin (Jira)
[jira] [Updated] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyWithHeadersQuery)
Jess Jin (Jira)
[jira] [Updated] (KAFKA-20703) Implement query type 1 (TimestampedKeyWithHeadersQuery)
Jess Jin (Jira)
[PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) [kafka]
via GitHub
[PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka]
via GitHub
Re: [PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka]
via GitHub
Re: [PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka]
via GitHub
Re: [PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka]
via GitHub
Re: [PR] MINOR: Rename RequestChannelMetrics.apply to get [kafka]
via GitHub
[PR] Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka]
via GitHub
Re: [PR] KAFKA-20777: Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka]
via GitHub
Re: [PR] KAFKA-20777: Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka]
via GitHub
Re: [PR] KAFKA-20777: Make a closed StagedMergeIterator throw InvalidStateStoreException [kafka]
via GitHub
Re: [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka]
via GitHub
Re: [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Siddhartha Devineni (Jira)
[PR] MINOR: Document temporal collision window in offset-commit protocol [kafka]
via GitHub
Re: [PR] MINOR: Document temporal collision window in offset-commit protocol [kafka]
via GitHub
[jira] [Updated] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
[jira] [Updated] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
[jira] [Updated] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
[jira] [Updated] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
[jira] [Created] (KAFKA-20792) Kafka Streams FK LeftJoin - IllegalArgumentException: Invalid partition: -1
Patrik Kleindl (Jira)
[jira] [Updated] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-20088) CIDR-based Host Patterns for ACLs
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-20791) Bump log4j to 2.25.5
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-20741) Add ReadOnlyRecord Interface
Jess Jin (Jira)
[PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: LogReader interface cleanup (2/N) [kafka]
via GitHub
[PR] KAFKA-20791: Bump log4j to 2.25.5 [kafka]
via GitHub
Re: [PR] KAFKA-20791: Bump log4j to 2.25.5 [kafka]
via GitHub
Re: [PR] KAFKA-20791: Bump log4j to 2.25.5 [kafka]
via GitHub
[jira] [Updated] (KAFKA-20791) Bump log4j to 2.25.5
Federico Valeri (Jira)
[jira] [Assigned] (KAFKA-20791) Bump log4j to 2.25.5
Federico Valeri (Jira)
[jira] [Created] (KAFKA-20791) Bump log4j to 2.25.5
Federico Valeri (Jira)
[PR] KAFKA-20773: Bump jackson to 2.21.5 [kafka]
via GitHub
Re: [PR] KAFKA-20773: Bump jackson to 2.21.5 [kafka]
via GitHub
Re: [PR] KAFKA-20773: Bump jackson to 2.21.5 [kafka]
via GitHub
[jira] [Updated] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Federico Valeri (Jira)
[PR] KAFKA-20650: Share ClientQuotaCallback across broker and controller in combined mode [kafka]
via GitHub
Re: [PR] KAFKA-20650: Share ClientQuotaCallback across broker and controller in combined mode [kafka]
via GitHub
[PR] KAFKA-19877: Clarify Deserializer ByteBuffer position/limit contract [kafka]
via GitHub
Re: [PR] KAFKA-19877: Clarify Deserializer ByteBuffer position/limit contract [kafka]
via GitHub
[PR] KAFKA-20786: Bound IntegrationTestUtils.readRecords on real elapsed time [kafka]
via GitHub
Re: [PR] KAFKA-20786: Bound IntegrationTestUtils.readRecords on real elapsed time [kafka]
via GitHub
[PR] KAFKA-20597: Fix prefixScan overflow for prefixes with no upper bound in in-memory state stores [kafka]
via GitHub
Re: [PR] KAFKA-20597: Fix prefixScan overflow for prefixes with no upper bound in in-memory state stores [kafka]
via GitHub
Re: [PR] KAFKA-5761: Serializer API should support ByteBuffer [kafka]
via GitHub
Re: [PR] KAFKA-5761: Serializer API should support ByteBuffer [kafka]
via GitHub
Re: [PR] Question: assumptions around ProduceResponse → ProducerBatch matching [kafka]
via GitHub
Re: [PR] Question: assumptions around ProduceResponse → ProducerBatch matching [kafka]
via GitHub
Re: [PR] KAFKA-19631 Admin#describeReplicaLogDirs does not handle error correctly [kafka]
via GitHub
Re: [PR] KAFKA-19631 Admin#describeReplicaLogDirs does not handle error correctly [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KAFKA-14229 Support for nested structures: HoistField [kafka]
via GitHub
Re: [PR] KAFKA-14229 Support for nested structures: HoistField [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Ziyun Fu (Jira)
[jira] [Created] (KAFKA-20790) Promote streams assignor API to public module
Ziyun Fu (Jira)
[jira] [Assigned] (KAFKA-20790) Promote streams assignor API to public module
Ziyun Fu (Jira)
[jira] [Assigned] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Ziyun Fu (Jira)
[jira] [Created] (KAFKA-20789) KIP-1357: Promote streams assignor API to public module
Ziyun Fu (Jira)
[PR] KAFKA-20683: Add broker side custom assignors for "streams" groups [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
Re: [PR] KAFKA-20790: Promote streams assignor API to public module [kafka]
via GitHub
[jira] [Updated] (KAFKA-20788) Expose Rebalance Cause to RebalanceConsumer and Metrics
Aditya Kousik (Jira)
[jira] [Created] (KAFKA-20788) Expose Rebalance Cause to RebalanceConsumer and Metrics
Aditya Kousik (Jira)
[jira] [Created] (KAFKA-20787) Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins
Lucy Liu (Jira)
[jira] [Updated] (KAFKA-20786) Build sometimes times out on streams tests
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Lianet Magrans (Jira)
[PR] KAFKA-16630: Fix flaky classic consumer poll test [kafka]
via GitHub
Re: [PR] KAFKA-16630: Fix flaky classic consumer poll test [kafka]
via GitHub
Re: [PR] KAFKA-16630: Fix flaky classic consumer poll test [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Lianet Magrans (Jira)
[jira] [Assigned] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation
majialong (Jira)
[jira] [Commented] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation
majialong (Jira)
Earlier messages
Later messages