jira  

Messages by Thread

• [jira] [Created] (KAFKA-20415) Dynamic config for enabling dlq Sushant Mahajan (Jira)
• [jira] [Commented] (KAFKA-20412) Fix prefixScan for KV-Store with headers Uladzislau Blok (Jira)
  • [jira] [Commented] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers Siddhartha Devineni (Jira)
  • [jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers Shekhar Prasad Rajak (Jira)
  • [jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers Uladzislau Blok (Jira)
  • [jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers Bill Bejeck (Jira)
• [jira] [Assigned] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Shekhar Prasad Rajak (Jira)
• [jira] [Assigned] (KAFKA-20155) Implement lazy deserialization mechanism Shekhar Prasad Rajak (Jira)
• [jira] [Updated] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20414) StreamsPartitioner should pass in headers Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20277) Verify existing IQv2 methods for SessionStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20220) Enable TimestampedKVStoreWithHeaders in DSL Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20307) Add Interactive Queries (IQv1) support for headers-aware stores Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20304) Implement all required ReadOnly*Facade classes for headers stores Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20303) Optimize deserializers and HeadersBytesStore Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20327) Add SessionStore overrides to Abstract decorators Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20219) Override `getPosition` correctly for TimestampedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20260) Upgrade path from plain KV store to headers store Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20182) Upgrade gradle to 9.3.x Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20182) Upgrade gradle to 9.3.x Chia-Ping Tsai (Jira)
  • [jira] [Updated] (KAFKA-20182) Upgrade gradle to 9.3.x Chia-Ping Tsai (Jira)
• [PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka] via GitHub
  • Re: [PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka] via GitHub
  • Re: [PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit Chia-Ping Tsai (Jira)
• 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-16263 : Add Kafka Streams docs about available listeners/callback [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
• [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka] via GitHub
  • Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka] via GitHub
  • Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka] via GitHub
  • Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka] via GitHub
  • Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka] via GitHub
• [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
  • Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka] via GitHub
• [jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins Matthias J. Sax (Jira)
• [PR] MINOR: Fix log statement formatting in KafkaAdminClient [kafka] via GitHub
  • Re: [PR] MINOR: Fix log statement formatting in KafkaAdminClient [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20413) ListValueStore and outer join stores don't propagate headers to serdes Alieh Saeedi (Jira)
• [jira] [Updated] (KAFKA-20413) ListValueStore and suppress buffer stores don't propagate headers to serdes Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20413) ListValueStore and suppress buffer stores don't propagate headers to serdes Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20413) ListValueStore and outer join stores don't propagate headers to serdes Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization Matthias J. Sax (Jira)
• [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread [kafka] via GitHub
• [PR] MINOR: fix typo in KafkaAdminClient to align the meaning [kafka] via GitHub
  • Re: [PR] MINOR: fix typo in KafkaAdminClient to align the meaning [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
  • [jira] [Assigned] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-13169) Flaky Test QueryableStateIntegrationTest.shouldBeAbleToQueryStateWithNonZeroSizedCache Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-13513) Flaky test AdjustStreamThreadCountTest Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
  • [jira] [Updated] (KAFKA-20412) Fix prefixScan for KV-Store with headers Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20412) Fix prefixScan for KV-Store with headers Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-20397) Review to improve metadata error check before blocking on buffer data in consumer Nilesh Kumar (Jira)
• [PR] MINOR: Follow up integration tests for KIP-1035 [kafka] via GitHub
  • Re: [PR] MINOR: Follow up integration tests for KIP-1035 [kafka] via GitHub
• [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
  • Re: [PR] MINOR: Flaky test fixes [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20376) Update site docs for rebalance protocol page Lianet Magrans (Jira)
• Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka] via GitHub
  • Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20408) Remove ConsumerMetrics Chia-Ping Tsai (Jira)
• [PR] Ehuskey/3.0 li baseline [kafka] via GitHub
  • Re: [PR] Ehuskey/3.0 li baseline [kafka] via GitHub
• [PR] Jclarysse/backport fix producer msg corruption to 38 [kafka] via GitHub
  • Re: [PR] KAFKA-19012: fix rare producer message corruption [kafka] via GitHub
• [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
  • Re: [PR] KAFKA-20393: Fix stickyNode using stale IP when broker address changes [kafka] via GitHub
• Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
  • Re: [PR] KAFKA-20264: fix overwrite in recursive parent-node matching [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20409) Don't expose internal group configs unless they are user-defined. majialong (Jira)
• [PR] MINOR: Suppress the deprecation warning for `LOG_CLEANER_ENABLE_PROP` in `LogCleanerIntegrationTest` [kafka] via GitHub
  • Re: [PR] MINOR: Suppress the deprecation warning for `LOG_CLEANER_ENABLE_PROP` in `LogCleanerIntegrationTest` [kafka] via GitHub
• [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
  • Re: [PR] MINOR: Fixed documentation on formatting new brokers [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20339) Make offload config private for 4.3 David Jacot (Jira)
• [jira] [Created] (KAFKA-20411) Move org.apache.kafka.common.utils.Utils to org.apache.kafka.common.utils.internals.Utils Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20411) Move org.apache.kafka.common.utils.Utils to org.apache.kafka.common.utils.internals.Utils Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20331) Update upgrade.md to mention new assignment offload configs David Jacot (Jira)
• [jira] [Resolved] (KAFKA-20240) Update upgrade.md to mention new batching and background thread pool configs David Jacot (Jira)
• [jira] [Resolved] (KAFKA-20405) Remove numClassicGroupsTimelineCounter David Jacot (Jira)
• [jira] [Assigned] (KAFKA-19086) Extending support for Microsecond Precision for Kafka Connect Omnia Ibrahim (Jira)
• [jira] [Created] (KAFKA-20410) Add DLQ configuration parameters as defined in the KIP Sanskar Jhajharia (Jira)
• [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
  • Re: [PR] KAFKA-20388: Move LogConfigTest from core to storage [kafka] via GitHub
• [jira] [Commented] (KAFKA-20313) Cleanup "leaking" internal interface `WindowedSerializer` Siddhartha Devineni (Jira)
• [PR] MINOR: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
  • Re: [PR] KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) [kafka] via GitHub
• [jira] [Updated] (KAFKA-19086) Extending support for Microsecond Precision for Kafka Connect Pritam Kumar (Jira)
  • [jira] [Updated] (KAFKA-19086) Extending support for Microsecond Precision for Kafka Connect Pritam Kumar (Jira)
• [PR] KAFKA-20405: Remove redundant `numClassicGroupsTimelineCounter` [kafka] via GitHub
  • Re: [PR] KAFKA-20405: Remove redundant `numClassicGroupsTimelineCounter` [kafka] via GitHub
• [jira] [Commented] (KAFKA-20409) Don't expose internal group configs unless they are user-defined. Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20409) Don't expose internal group configs unless they are user-defined. Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20409) Don't expose internal group configs unless they are user-defined. Chia-Ping Tsai (Jira)
• [PR] MINOR: Fix duplicated 'not' in EmbeddedConnect exception messages [kafka] via GitHub
  • Re: [PR] MINOR: Fix duplicated 'not' in EmbeddedConnect exception messages [kafka] via GitHub
  • Re: [PR] MINOR: Fix duplicated 'not' in EmbeddedConnect exception messages [kafka] via GitHub
  • Re: [PR] MINOR: Fix double negative typos in Javadoc and exception messages [kafka] via GitHub
• Re: [PR] KAFKA-20024: wmic os get osarchitecture is unreliable for detecting OS bitness in bat scripts [kafka] via GitHub
  • Re: [PR] KAFKA-20024: wmic os get osarchitecture is unreliable for detecting OS bitness in bat scripts [kafka] via GitHub
• Re: [PR] [WIP] KIP-966: Designated Leadership elections [kafka] via GitHub
  • Re: [PR] [WIP] KIP-966: Designated Leadership elections [kafka] via GitHub
• Re: [PR] KAFKA-19615: Enable to ducker-ak to isolate the ducker containers [kafka] via GitHub
  • Re: [PR] KAFKA-19615: Enable to ducker-ak to isolate the ducker containers [kafka] via GitHub
• Re: [PR] KAFKA-19673: Disallow create too many partitions also in createPartitions [kafka] via GitHub
• Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] via GitHub
  • Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka] via GitHub
• Re: [PR] KAFKA 18238 - fIdentify the first commit where a test became flaky [kafka] via GitHub
  • Re: [PR] KAFKA 18238 - fIdentify the first commit where a test became flaky [kafka] via GitHub
• Re: [PR] KAFKA-20179 : streams - Avoid headers deserialization during changelogging [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag. Nilesh Kumar (Jira)
• [PR] KAFKA-20389: Add 'internal' flag to ConfigKeyInfo [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Add 'internal' flag to ConfigKeyInfo [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Add 'internal' flag to ConfigKeyInfo [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Add 'internal' flag to ConfigKeyInfo [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Add 'internal' flag to ConfigKeyInfo [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Filter internal keys from connector plugin config REST response [kafka] via GitHub
  • Re: [PR] KAFKA-20389: Filter internal keys from connector plugin config REST response [kafka] via GitHub
• [jira] [Commented] (KAFKA-20398) Memory leak when stream threads are replaced chomingi (Jira)
• [PR] KAFKA-18309: Change log.segment.bytes config type from INT to LONG [kafka] via GitHub
  • Re: [PR] KAFKA-18309: Change log.segment.bytes config type from INT to LONG [kafka] via GitHub
  • Re: [PR] KAFKA-18309: Change log.segment.bytes config type from INT to LONG [kafka] via GitHub
• [jira] [Resolved] (KAFKA-13819) Add application.server to Streams assignor logs when set Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20408) Remove ConsumerMetrics Muralidhar Basani (Jira)
• [jira] [Assigned] (KAFKA-20408) Remove ConsumerMetrics Muralidhar Basani (Jira)
• [PR] KAFKA-20408 : Remove ConsumerMetrics wrapper [kafka] via GitHub
  • Re: [PR] KAFKA-20408 : Remove ConsumerMetrics wrapper [kafka] via GitHub
• [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
  • Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread shutdown [kafka] via GitHub
• [jira] [Created] (KAFKA-20408) Remove ConsumerMetrics Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20407) Consider adding transaction state log append latency metrics sanghyeok An (Jira)
• [jira] [Commented] (KAFKA-15501) Kafka to KRaft combined mode migration v3.5 Shekhar Prasad Rajak (Jira)

• Earlier messages
• Later messages