jira  

Messages by Thread

• [jira] [Assigned] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager Lianet Magrans (Jira)
• [jira] [Updated] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add Xi Wang (Jira)
• [jira] [Created] (KAFKA-20804) Reduce lock contention in ProducerMetadata#add Xi Wang (Jira)
• [jira] [Updated] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs Shekhar Prasad Rajak (Jira)
  • [jira] [Updated] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs Andrew Schofield (Jira)
• [jira] [Assigned] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs Shekhar Prasad Rajak (Jira)
• [jira] [Created] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs Shekhar Prasad Rajak (Jira)
• [PR] KAFKA-20783: Release locks on exception for local reads within remote calls (5/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20783: Release locks on exception for local reads within remote calls (5/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20783: Release locks on exception for local reads within remote calls (5/N) [kafka] via GitHub
• [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
  • Re: [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
  • Re: [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
  • Re: [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
  • Re: [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
  • Re: [PR] KAFKA-20768: Add transactional and IQ isolation to time-ordered RocksDB stores [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20768) RocksDB SegmentedStore readOnly implementation Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders Bill Bejeck (Jira)
• [jira] [Updated] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders Bill Bejeck (Jira)
  • [jira] [Updated] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-20704) Implement query type 2 (TimestampedRangeWithHeadersQuery) Jess Jin (Jira)
• [jira] [Updated] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse Apoorv Mittal (Jira)
  • [jira] [Updated] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse Apoorv Mittal (Jira)
• [jira] [Assigned] (KAFKA-20577) Producer configuration to define allocation strategy Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls Lianet Magrans (Jira)
• [PR] KAFKA-20783: Clear held partitions failing min-bytes (4/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20783: Clear held partitions failing min-bytes (4/N) [kafka] via GitHub
  • Re: [PR] KAFKA-20783: Clear held partitions failing min-bytes (4/N) [kafka] via GitHub
• [PR] KAFKA-20802: Skip terminated threads when building thread leak reports [kafka] via GitHub
  • Re: [PR] KAFKA-20802: Skip terminated threads when building thread leak reports [kafka] via GitHub
  • Re: [PR] KAFKA-20802: Avoid NPE in thread leak reporting [kafka] via GitHub
  • Re: [PR] KAFKA-20802: Avoid NPE in thread leak reporting [kafka] via GitHub
• [PR] KAFKA-20667: Add principal-level index to AclCache to fix O(N) ACL scanning [kafka] via GitHub
• [jira] [Created] (KAFKA-20802) ClusterTestExtensions#afterEach throws NPE when a detected thread terminates before the leak report is built Eric Chang (Jira)
• [PR] MINOR: Correct broker dynamic configuration names in the documentation [kafka] via GitHub
• [jira] [Commented] (KAFKA-9613) CorruptRecordException: Found record size 0 smaller than minimum record overhead Santosh Kumar Sahu (Jira)
• Re: [PR] KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup [kafka] via GitHub
• Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka] via GitHub
  • Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka] via GitHub
• Re: [PR] KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang [kafka] via GitHub
  • Re: [PR] KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang [kafka] via GitHub
• Re: [PR] KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" [kafka] via GitHub
• [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20786) Build sometimes times out on streams tests Matthias J. Sax (Jira)
• [PR] KAFKA-20760: Break out PositionRestartIntegrationTest into sub-class for transactional stores [kafka] via GitHub
  • Re: [PR] KAFKA-20760: Break out PositionRestartIntegrationTest into sub-class for transactional stores [kafka] via GitHub
  • Re: [PR] KAFKA-20760: Break out PositionRestartIntegrationTest into sub-class for transactional stores [kafka] via GitHub
• Re: [PR] KAFKA-20744: Add back `rack.aware.assignment.tags` config [kafka] via GitHub
  • Re: [PR] KAFKA-20744: Add back `rack.aware.assignment.tags` config [kafka] via GitHub
  • Re: [PR] KAFKA-20744: Add back `rack.aware.assignment.tags` config [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20400) Enable VersionedKeyValueStoreWithHeaders in DSL Alieh Saeedi (Jira)
• [jira] (KAFKA-20259) Verify IQv1 and IQv2 does not break Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20259) Verify IQv1 and IQv2 does not break Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Alieh Saeedi (Jira)
• [PR] KAFKA-20757: Expand transactional state-store unit-test coverage [kafka] via GitHub
• Re: [PR] KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Bill Bejeck (Jira)
• [jira] [Assigned] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-20723) Harden ShareGroupDLQStateManager Sushant Mahajan (Jira)
• [PR] KAFKA-20698: Remove deprecated ConsumerRecords(Map) constructor [kafka] via GitHub
  • Re: [PR] KAFKA-20698: Remove deprecated ConsumerRecords(Map) constructor [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20771) Honor DLQ topic configs so as to not overwhelm it with large produce requests. Apoorv Mittal (Jira)
• Re: [PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka] via GitHub
  • Re: [PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka] via GitHub
• [jira] [Updated] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-20801) KIP-1366: Configurable Segment Interval for Window and Session Stores Hannes Buseyne (Jira)
• [jira] [Created] (KAFKA-20800) Adjust Kafka security logging with more context Vladimir Yatsenko (Jira)
• [jira] [Resolved] (KAFKA-20761) Add client logs for consumer group configs defined on the broker Lianet Magrans (Jira)
• [jira] [Assigned] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
• [jira] [Commented] (KAFKA-20799) Introduce new error for consumer/share group name collision majialong (Jira)
  • [jira] [Commented] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
• Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] via GitHub
  • Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] via GitHub
  • Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] via GitHub
  • Re: [PR] KAFKA-19584: add SecurityManager shim support to native image [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20629) Add ducktape system tests for topology description plugin TengYao Chi (Jira)
• [jira] [Assigned] (KAFKA-20797) KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect Gaurav Narula (Jira)
• [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
  • [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
  • [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
  • [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
  • [jira] [Updated] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
• [jira] [Created] (KAFKA-20799) Introduce new error for consumer/share group name collision Luke Chen (Jira)
• [PR] KAFKA-10369: Add TimestampAndOffset value type of deduplication store (1/N) [kafka] via GitHub
• [PR] MINOR: Enhance MirrorMaker 2 fault tolerance for topic truncation and reset scenarios [kafka] via GitHub
• Re: [PR] KAFKA-20297: Move `org.apache.kafka.common.utils.Utils` to `org.apache.kafka.common.utils.internals.Utils` [kafka] via GitHub
  • Re: [PR] KAFKA-20297: Move `org.apache.kafka.common.utils.Utils` to `org.apache.kafka.common.utils.internals.Utils` [kafka] via GitHub
• Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka] via GitHub
  • Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka] via GitHub
• Re: [PR] KAFKA-19470 Avoid creating loggers repeatedly to affect the performance of request processing [kafka] via GitHub
  • Re: [PR] KAFKA-19470 Avoid creating loggers repeatedly to affect the performance of request processing [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders Lucy Liu (Jira)
• [jira] [Created] (KAFKA-20798) Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders Lucy Liu (Jira)
• [jira] [Commented] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager Nilesh Kumar (Jira)
  • [jira] [Commented] (KAFKA-16628) Add system test for validating static consumer bounce and assignment when not eager Lianet Magrans (Jira)
• [PR] KAFKA-20568: Unify DSL store accessor and header-aware builder naming [kafka] via GitHub
  • Re: [PR] KAFKA-20568: Unify DSL store accessor and header-aware builder naming [kafka] via GitHub
  • Re: [PR] KAFKA-20568: Unify DSL store accessor and header-aware builder naming [kafka] via GitHub
• [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka] via GitHub
  • Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka] via GitHub
  • Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka] via GitHub
• [PR] KAFKA-17821: the set of configs displayed by `logAll` could be invalid [kafka] via GitHub
  • Re: [PR] KAFKA-17821: the set of configs displayed by `logAll` could be invalid [kafka] via GitHub
  • Re: [PR] KAFKA-17821: the set of configs displayed by `logAll` could be invalid [kafka] via GitHub
• [jira] [Commented] (KAFKA-20766) SASL channel authentication may block under slow/broken reverse DNS resolution during connection establishment dongfang (Jira)
• [jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path Jira
  • [jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path Muralidhar Basani (Jira)
• Re: [PR] KAFKA-18053 Clean up topology config [kafka] via GitHub
  • Re: [PR] KAFKA-18053 Clean up topology config [kafka] via GitHub
• Re: [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] via GitHub
  • Re: [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] via GitHub
• Re: [PR] KAFKA-19881: change CVE scanner workflow to run on active branches (wip) [kafka] via GitHub
• Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka] via GitHub
• Re: [PR] KAFKA-20538: Make RocksDBTimeOrderedKeyValueBuffer headers-aware [kafka] via GitHub
  • Re: [PR] KAFKA-20538: Make RocksDBTimeOrderedKeyValueBuffer headers-aware [kafka] via GitHub
  • Re: [PR] KAFKA-20538: Make RocksDBTimeOrderedKeyValueBuffer headers-aware [kafka] via GitHub
• Re: [PR] KAFKA-14227 Support for nested structures: MaskField [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20735) Streams logs ERROR "Failed to acquire lock while closing the state store" for lock contention during back-to-back rebalances Nilesh Kumar (Jira)
• [PR] KAFKA-4637: Add system test for multiple listeners [kafka] via GitHub
  • Re: [PR] KAFKA-4637: Add system test for multiple listeners [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20568) Unify DSL Store Accessor and Header-Aware Builder Naming Nilesh Kumar (Jira)
• [PR] KAFKA-20781: Fix flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls [kafka] via GitHub
  • Re: [PR] KAFKA-20781: Fix flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls [kafka] via GitHub
  • Re: [PR] KAFKA-20781: Fix flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls [kafka] via GitHub
  • Re: [PR] KAFKA-20781: Fix flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls [kafka] via GitHub
• Re: [PR] KAFKA-19010: Added JVM argument to default configuration [kafka] via GitHub
• Re: [PR] KAFKA-18967: Added additional MetadataSchemaCheckerTool tests [kafka] via GitHub
• Re: [PR] KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer [kafka] via GitHub
  • Re: [PR] KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer [kafka] via GitHub
• [jira] [Assigned] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer Nilesh Kumar (Jira)
• [jira] [Created] (KAFKA-20797) KIP-1365: Transform Observability and Skipped Record Handling for Kafka Connect Pritam Kumar (Jira)
• Re: [PR] Switch to using scala 2.9.2 [kafka] via GitHub
• [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] via GitHub
  • Re: [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] via GitHub
  • Re: [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] via GitHub
  • Re: [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] via GitHub
  • Re: [PR] KAFKA-20215: Add integration test for log directory cordoning [kafka] via GitHub
• [PR] MINOR: Move ByteBuffer streams to internal package [kafka] via GitHub
  • Re: [PR] MINOR: Move ByteBufferInputStream and ByteBufferOutputStream to internal package [kafka] via GitHub
• [PR] MINOR: Fix broken relative links in docs/ [kafka] via GitHub
  • Re: [PR] MINOR: Fix broken relative links in docs/ [kafka] via GitHub
  • Re: [PR] MINOR: Fix broken relative links in docs/ [kafka] via GitHub
  • Re: [PR] MINOR: Fix broken relative links in docs/ [kafka] via GitHub
• Re: [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
• Re: [PR] MINOR: Fix incorrect config name and stale links in Log Compaction docs [kafka] via GitHub
  • Re: [PR] MINOR: Fix incorrect config name and stale links in Log Compaction docs [kafka] via GitHub
• [PR] KAFKA-18951: Correct topic name in client example docs [kafka] via GitHub
  • Re: [PR] KAFKA-18951: Correct topic name in client example docs [kafka] via GitHub
• [jira] [Commented] (KAFKA-18951) Validate client code and documentation in examples/ directory Gabriel Dutra (Jira)
• [PR] MINOR: Rewrite TransactionMetadataTest from Scala to Java [kafka] via GitHub
  • Re: [PR] MINOR: Rewrite TransactionMetadataTest from Scala to Java [kafka] via GitHub
  • Re: [PR] MINOR: Rewrite TransactionMetadataTest from Scala to Java [kafka] via GitHub
• [PR] Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] HOTFIX: Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
  • Re: [PR] HOTFIX: Reduce lock contention in ProducerMetadata#add [kafka] via GitHub
• [PR] KAFKA-20796: Fix num-open-iterators metric for timestamped range queries [kafka] via GitHub
  • Re: [PR] KAFKA-20796: Fix num-open-iterators metric for timestamped range queries [kafka] via GitHub
  • Re: [PR] KAFKA-20796: Fix num-open-iterators metric for timestamped range queries [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20796) num-open-iterators metric under-counts iterators from MeteredTimestampedKeyValueStore dino2895 (Jira)
• [jira] [Assigned] (KAFKA-20795) RequestConvertToJson#request and RequestConvertToJson#response could be implemented by generator dino2895 (Jira)
• [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
  • Re: [PR] KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins [kafka] via GitHub
• [PR] let metered store's readonly override with header aware store [kafka] via GitHub
  • Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20798: Add readOnly(IsolationLevel) to TimestampedWindowStoreWithHeaders and SessionStoreWithHeaders [kafka] via GitHub
  • 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

• Earlier messages
• Later messages