jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
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)
[jira] [Assigned] (KAFKA-15501) Kafka to KRaft combined mode migration v3.5
Shekhar Prasad Rajak (Jira)
[jira] [Created] (KAFKA-20406) Use the topic-specific compression level for compaction instead of the default level
Chia-Ping Tsai (Jira)
[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-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-20297: Move `org.apache.kafka.common.utils.Utils` to `org.apache.kafka.common.utils.internals.Utils` [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20346) LogCleaner#cleaners should be thread-safe
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-20019: Fetch responses can exceed maxBytes when mixing local and tiered storage partitions [kafka]
via GitHub
[jira] [Updated] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings
Muralidhar Basani (Jira)
[jira] [Assigned] (KAFKA-20405) Remove numClassicGroupsTimelineCounter
Nick Guo (Jira)
[jira] [Created] (KAFKA-20405) Remove numClassicGroupsTimelineCounter
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19566) Deprecate ClientQuotaCallback#updateClusterMetadata
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings
Muralidhar Basani (Jira)
Re: [PR] KAFKA-13819: Add application.server to Streams assignor logs when set [kafka]
via GitHub
Re: [PR] KAFKA-13819: Add application.server to Streams assignor logs when set [kafka]
via GitHub
Re: [PR] KAFKA-13819: Add application.server to Streams assignor logs when set [kafka]
via GitHub
[PR] KAFKA-20173: Propagate headers into serde: CachingKeyValueStore [kafka]
via GitHub
Re: [PR] KAFKA-20173: Propagate headers into serde: CachingKeyValueStore [kafka]
via GitHub
Re: [PR] KAFKA-20173: Propagate headers into serde: CachingKeyValueStore [kafka]
via GitHub
Re: [PR] [WIP] KAFKA-20412: Propagate headers into serde: CachingKeyValueStore [kafka]
via GitHub
[jira] [Commented] (KAFKA-20394) Selector Channel not syneced with client Metadata
gomudayya (Jira)
Re: [PR] KAFKA-20135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
Re: [PR] refactor: simplify code [kafka]
via GitHub
[jira] [Updated] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag.
Nilesh Kumar (Jira)
[jira] [Updated] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag.
Nilesh Kumar (Jira)
Re: [PR] KAFKA-2526: command line --producer-property wins [kafka]
via GitHub
[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
Earlier messages
Later messages