Messages by Thread
-
[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
-
[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
-
[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
-
[PR] KAFKA-16836: Fix incorrect suspend reason in standby update listener [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-16836) Suspend reason of standby update listener is not correct
Lucas Brutschy (Jira)
-
[jira] [Created] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Alieh Saeedi (Jira)
-
[jira] [Commented] (KAFKA-20184) jose4j marked as compileOnly in clients module causes ClassNotFoundException at runtime for OAuth authentication
Kirk True (Jira)
-
[jira] [Commented] (KAFKA-20013) Convert docs to Markdown
Kirk True (Jira)
-
[jira] [Commented] (KAFKA-19863) Add documentation on how to implement a custom exception handler
Rajarshi Misra (Jira)
-
[jira] [Assigned] (KAFKA-19863) Add documentation on how to implement a custom exception handler
Rajarshi Misra (Jira)
-
[jira] [Assigned] (KAFKA-19650) Add message key to org.apache.kafka.clients.producer.RecordMetadata
Rajarshi Misra (Jira)
-
[jira] [Closed] (KAFKA-19960) Spurious failure to close StateDirectory due to some task directories still locked
Mikael Carlstedt (Jira)
-
[jira] [Assigned] (KAFKA-20192) Brittle logic in ReconfigurableQuorumIntegrationTest
Dmitry Werner (Jira)
-
[PR] MINOR: Fix lost custom error message in CoordinatorPartitionWriter#append [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20192) Brittle logic in ReconfigurableQuorumIntegrationTest
Mickael Maison (Jira)
-
[PR] 4.2 docs [kafka]
via GitHub
-
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (5/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-17251: Avoid WARN on cleanup when state directory only contains process metadata. [kafka]
via GitHub
-
[PR] MINOR: Move ProducerIntegrationTest to clients-integration-tests and rewrite in Java [kafka]
via GitHub
-
[PR] KAFKA-20106: Ensure reconciled assignment updated within poll [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-17302) ReplicaFetcher changes for fetching from tiered offset
Kamal Chandraprakash (Jira)
-
[jira] [Updated] (KAFKA-15433) Follower fetch from tiered offset
Kamal Chandraprakash (Jira)
-
[PR] KAFKA-18046: Avoid repeated logger creation in InternalTopicManager [kafka]
via GitHub
-
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (4/N) [kafka]
via GitHub
-
[PR] MINOR: Rename ConfiguredTopology to TopologyValidationResult [kafka]
via GitHub
-
Re: [PR] KAFKA-19048: Minimal movement replica balancing algorithm for reassignment [kafka]
via GitHub
-
Re: [PR] jprnt02 [kafka]
via GitHub
-
Re: [PR] MINOR: Note KS broker replication factor limitation [kafka]
via GitHub
-
Re: [PR] [Draft] KAFKA-19393: Consolidate consumer assignment state views. [kafka]
via GitHub
-
[PR] KAFKA-20159: Group configuration for share.delivery.count.limit [kafka]
via GitHub
-
Re: [PR] KAFKA-8958 : Fix Kafka Streams JavaDocs with regard to used Serdes [kafka]
via GitHub
-
[PR] KAFKA-20173: Propagate headers into serde 1/N [kafka]
via GitHub
-
[PR] KAFKA-20131: Clear end-offset request flag after failed list-offsets [kafka]
via GitHub
-
[PR] MINOR: Remove Evolving annotation from GroupState [kafka]
via GitHub
-
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (3/N) [kafka]
via GitHub
-
[PR] MINOR: Add 4.2.0 to the CVE Scanner [kafka]
via GitHub
-
[PR] KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20191) Disallow sendOffsetsToTransaction from committing offsets for unassigned partitions
Ken Huang (Jira)
-
[jira] [Created] (KAFKA-20191) Disallow sendOffsetsToTransaction from committing offsets for unassigned partitions
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20191) Disallow sendOffsetsToTransaction from committing offsets for unassigned partitions
Chia-Ping Tsai (Jira)
-
[jira] [Resolved] (KAFKA-20190) Apache Kafka 3.7.2 not listed on the web page
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Mickael Maison (Jira)
-
[jira] [Assigned] (KAFKA-1704) Add PartitionConfig besides LogConfig
Rajarshi Misra (Jira)
-
Re: [PR] KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP] [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20190) Apache Kafka 3.7.2 not listed on the web page
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20190) Apache Kafka 3.7.2 not listed on the web page
Matthias J. Sax (Jira)
-
[jira] [Comment Edited] (KAFKA-20189) KAFKA-SHELL: Add character class support to GlobComponent
Akram Khan (Jira)
-
[jira] [Commented] (KAFKA-20189) KAFKA-SHELL: Add character class support to GlobComponent
Akram Khan (Jira)
-
[PR] KAFKA-20189: Add character class support to GlobComponent [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20035) Prevent data loss during partition expansion by enforcing "earliest" offset reset for dynamically added partitions
Andrew Schofield (Jira)
-
[PR] MINOR: Replace Properties with Map in ControllerConfigurationValidator validation path [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-5246) Remove backdoor that allows any client to produce to internal topics
TaiJuWu (Jira)
-
[jira] (KAFKA-20177) Handle malformed partition.metadata without NullPointerException
Abdgali Yerkingaliyev (Jira)
-
[jira] [Created] (KAFKA-20189) KAFKA-SHELL: Add character class support to GlobComponent
Akram Khan (Jira)
-
[jira] [Assigned] (KAFKA-5246) Remove backdoor that allows any client to produce to internal topics
Ming-Yen Chung (Jira)
-
[PR] KAFKA-19976: Deprecate streams-scala module [kafka]
via GitHub
-
Re: [PR] KAFKA-19889 max.connections.per.ip.overrides does not apply overrides to all IPs for multi-IP hostnames [kafka]
via GitHub
-
Re: [PR] KAFKA-19553: Add comprehensive unit tests for TemperatureDemo streams example [kafka]
via GitHub
-
Re: [PR] fix(windows): replace deprecated wmic command on Windows 11 [kafka]
via GitHub
-
Re: [PR] Kafka 16582 [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-10863) Conver CONTROL_RECORD_KEY_SCHEMA_VERSION to use auto-generated protocal
Chia-Ping Tsai (Jira)
-
[PR] MINOR: Add argument description for --override option [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-1704) Add PartitionConfig besides LogConfig
Rajarshi Misra (Jira)
-
[jira] [Updated] (KAFKA-20186) Cluster Mirroring
Federico Valeri (Jira)
-
Re: [PR] Return friendly prompt when no quota configs found [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20066) Implement KIP-1251: Assignment epochs for consumer groups
Matthias J. Sax (Jira)
-
[jira] [Commented] (KAFKA-20106) Improve behaviour of consumer assignment API under async reconciliations
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20106) Improve behaviour of consumer assignment API under async reconciliations
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20188) Implement timeout/expiration for OffsetsRequestManager.fetchOffsets()
Kirk True (Jira)
-
[jira] [Created] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
-
[jira] [Updated] (KAFKA-17895) Expose KeyValueStore's approximateNumEntries as a metric
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20186) Cluster Mirroring
Federico Valeri (Jira)
-
[PR] KAFKA-19915: [2/3] Move LogDeleteRecordsResult to server module [kafka]
via GitHub
-
[PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-19149) Use KIP-877 in MirrorMaker
Mickael Maison (Jira)
-
[PR] [2/3] Move HostedPartition to server module [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20131) SubscriptionState endOffsetRequested remains permanently set if LIST_OFFSETS call fails
Viktor Somogyi-Vass (Jira)
-
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
-
[jira] [Created] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
-
[PR] KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
-
[jira] [Updated] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Federico Valeri (Jira)
-
[jira] [Created] (KAFKA-20184) jose4j marked as compileOnly in clients module causes ClassNotFoundException at runtime for OAuth authentication
Christian Semaan (Jira)
-
[jira] [Assigned] (KAFKA-20169) Support static membership for Kafka Streams with the streams rebalance protocol
sanghyeok An (Jira)
-
[PR] Corrected the stdout parsing in ShareConsumerPerformanceService [kafka]
via GitHub
-
[PR] KAFKA-20146: Add CI check to detect Python dependency conflicts [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20183) Share consumer group fails when group ID contains colon character
Luke Chen (Jira)
-
[PR] KAFKA-20183: Share consumer group fails when group ID contains colon character [kafka]
via GitHub