Messages by Thread
-
-
[jira] [Commented] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups
Akhilesh Chaganti (Jira)
-
[jira] [Created] (KAFKA-20200) Broken link to CVE list
Mickael Maison (Jira)
-
[jira] [Created] (KAFKA-20199) Evaluate whether BrokerId metrics tag should be renamed to NodeId or split by role
Ming-Yen Chung (Jira)
-
[jira] [Updated] (KAFKA-9920) Fix NetworkDegradeTest.test_rate test error
Viktor Somogyi-Vass (Jira)
-
[PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
-
[jira] [Resolved] (KAFKA-19774) Mechanism to cordon brokers and log directories
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
-
[jira] [Created] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
-
[jira] [Assigned] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
-
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
-
Re: [PR] KAFKA-13392 Resolve Timeout Exception triggering reassign partitions with --bootstrap-server option [kafka]
via GitHub
-
[PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Nick Guo (Jira)
-
[jira] [Created] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Nick Guo (Jira)
-
Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka]
via GitHub
-
Re: [PR] KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest [kafka]
via GitHub
-
[PR] streams: remove unnecessary empty statement in ProcessingExceptionHan… [kafka]
via GitHub
-
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
-
[PR] MINOR: Improve ValueTimestampHeader Serdes [kafka]
via GitHub
-
[PR] MINOR: Simplify Header Serdes [kafka]
via GitHub
-
[PR] KAFKA-20158: Adding MeteredSessionStore and tests [kafka]
via GitHub
-
[PR] KAFKA-20158: Adding interfaces for headers in session store [kafka]
via GitHub
-
[PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-20158: Add AggregationWithHeaders, serialization support and tests (1/N) [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20195) Better offset reset functionality for the new consumer group rebalance protocol
Levani Kokhreidze (Jira)
-
[jira] [Updated] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project)
Jira
-
[PR] KAFKA-20173: Propagate headers into serde 2/N [kafka]
via GitHub
-
[PR] KAFKA-20165 [2]: Integration tests to validate different OffsetFetch response behaviour on topic deleted [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-14579) Move DumpLogSegments to tools
Mickael Maison (Jira)
-
[PR] KAFKA-20066: Assignment epochs for consumer groups [kafka]
via GitHub
-
Re: [PR] MINOR: Use more appropriate exception when validate builder parameters [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20152) Remove unused CoordinatorMetrics#registry
Chia-Ping Tsai (Jira)
-
[jira] [Comment Edited] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
[PR] Add test scale up controller with "initial controllers" formatting [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Andrew Schofield (Jira)
-
[jira] [Updated] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
[jira] [Assigned] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
[jira] [Created] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Alieh Saeedi (Jira)
-
[PR] KAFKA-20090: rotate producerId when epoch exhausted during transaction completion. [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Ken Huang (Jira)
-
[PR] KAFKA-20168: Upgrade Jetty from 9.4.57 to 9.4.58 to fix CVE-2025-5115 (3.9) [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20181) cherry-pick KAFKA-20168 to 3.9 and 4.2
Chia-Ping Tsai (Jira)
-
Re: [PR] MINOR: Use a separate map to store acknowledgements in ShareAcknowledgementEvent. [kafka]
via GitHub
-
Re: [PR] KAFKA-19881: change CVE scanner workflow to run on active branches (wip) [kafka]
via GitHub
-
Re: [PR] Offset handling, data loss, fault tolerance added [kafka]
via GitHub
-
[PR] KAFKA-20152: Remove unused CoordinatorMetrics#registry [kafka]
via GitHub
-
[PR] Minor improve rocksdb test [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
Re: [PR] MINOR: Add store type (headers, timestamped, KV) downgrade tests [kafka]
via GitHub
-
[PR] MINOR: Implement TODOs to use StreamTask and StandbyTask whenever it's possible. [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-17789) State updater stuck when starting with empty state folder
Nikita Shupletsov (Jira)
-
[jira] [Commented] (KAFKA-17789) State updater stuck when starting with empty state folder
Nikita Shupletsov (Jira)
-
[jira] [Updated] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Matthias J. Sax (Jira)
-
[PR] MINOR: rename TaskRegistry methods to better reflect their purpose. (#21448) [kafka]
via GitHub