Messages by Thread
-
[PR] to 4.3 branch [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20512) Flaky/Failing org.apache.kafka.streams.integration.OuterJoinListValueStoreRestorationTest
Muralidhar Basani (Jira)
-
[PR] KAFKA-20512 : Fix flakiness - same output topic is being used for all parameterized tests [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20512) Flaky/Failing org.apache.kafka.streams.integration.OuterJoinListValueStoreRestorationTest
Muralidhar Basani (Jira)
-
[jira] [Commented] (KAFKA-16171) Controller failover during ZK migration can prevent metadata updates to ZK brokers
Alyssa Huang (Jira)
-
[jira] [Created] (KAFKA-20515) ZK leader failover during ZK migration can block migration
Alyssa Huang (Jira)
-
[PR] KAFKA-20514: kraft observers should use previous fetch response to decide where to send the next fetch [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20514) kraft observers should use previous fetch response to decide where to send the next fetch
Kevin Wu (Jira)
-
[jira] [Created] (KAFKA-20514) kraft observers should use previous fetch response to decide where to send the next fetch
Kevin Wu (Jira)
-
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-14192) Move registering and unregistering changelogs to state updater
Nikita Shupletsov (Jira)
-
[jira] [Commented] (KAFKA-14192) Move registering and unregistering changelogs to state updater
Nikita Shupletsov (Jira)
-
Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-14192) Move registering and unregistering changelogs to state updater
Nikita Shupletsov (Jira)
-
[jira] [Created] (KAFKA-20513) Add metrics to Kraft that measure the number of fetch timeouts and election timeouts
tony tang (Jira)
-
[PR] KAFKA-20297 Move SecurityUtils, ConfigUtils, LogContext, AppInfoParser into internal [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20510) [CVE-2026-34479] [log4j-1.2-api] [2.25.3]
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-20509) [CVE-2026-34480] [log4j-core] [2.25.3]
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-20369) Upgrade log4j2 from 2.25.3 to 2.25.4
Mickael Maison (Jira)
-
[jira] [Assigned] (KAFKA-20506) kafka-configs.sh can't delete the config from a offline broker when using bootstrap controller
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20512) Flaky/Failing org.apache.kafka.streams.integration.OuterJoinListValueStoreRestorationTest
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20512) Flaky/Failing org.apache.kafka.streams.integration.OuterJoinListValueStoreRestorationTest
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-9914) Mirror Maker 2 creates heartbeats kafka topics recursively
Viktor Somogyi-Vass (Jira)
-
[jira] [Commented] (KAFKA-20364) Remove control records reads from metadata module
Jun Cho (Jira)
-
[jira] [Created] (KAFKA-20511) Clarify consumer docs for rebalance callbacks & error handling
Lianet Magrans (Jira)
-
[PR] KAFKA-17871: avoid blocking the herder thread when producer flushing hangs [kafka]
via GitHub
-
[PR] MINOR: Rewrite DefaultApiVersionManagerTest from Scala to Java and move it to server module [kafka]
via GitHub
-
Re: [PR] MINOR: Keep pendingTask as WakeupFuture if currentTask is completed already. [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20510) [CVE-2026-34479] [log4j-1.2-api] [2.25.3]
Krishna Chidrawar (Jira)
-
[jira] [Created] (KAFKA-20509) [CVE-2026-34480] [log4j-core] [2.25.3] [adereporting]
Krishna Chidrawar (Jira)
-
[jira] [Updated] (KAFKA-20509) [CVE-2026-34480] [log4j-core] [2.25.3]
Krishna Chidrawar (Jira)
-
[jira] [Updated] (KAFKA-20508) Do not log/throw error/exception for corrupted tasks due to compacted changelog topic
Herman Kolstad Jakobsen (Jira)
-
[jira] [Created] (KAFKA-20508) Do not log/throw error/exception for corrupted tasks due to compacted changelog topic
Herman Kolstad Jakobsen (Jira)
-
Re: [PR] docs: clarify log compaction with example and tombstone explanation [kafka]
via GitHub
-
Re: [PR] KAFKA-19886 : Trogdor | Fix order of arguments in assertEquals in unit tests [kafka]
via GitHub
-
[PR] KAFKA-20362: Skip PR reviewer auto-fill when no usable email is available [kafka]
via GitHub
-
[PR] MINOR: Fix typos in UnifiedLog and LocalLog exception messages [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-19902) Consumer triggers OFFSET_OUT_OF_RANGE when committed offset uses stale epoch after leader change
Lianet Magrans (Jira)
-
[jira] [Assigned] (KAFKA-20505) Deadlock in KIP-932 share path: `SharePartition.rollbackOrProcessStateUpdates` completes future inside write lock, reenters `DelayedOperation` lock held by request handler
Apoorv Mittal (Jira)
-
[jira] [Created] (KAFKA-20507) Clarify consumer docs around commits without metadata & invalid position handling
Lianet Magrans (Jira)
-
[PR] MINOR: add missing javadoc to Metadata.java [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20506) kafka-configs.sh can't delete the config from a offline broker when using bootstrap controller
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20506) kafka-configs.sh can't delete the config from a offline broker when using bootstrap controller
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20506) kafka-configs.sh can't delete a nonexistent config from a offline broker when using bootstrap controller
Mickael Maison (Jira)
-
[PR] MINOR: Move CreateTopicsRequestTest to clients-integration-tests and rewrite in Java [kafka]
via GitHub
-
[PR] KAFKA-20506 kafka-configs.sh can't delete a nonexistent config from a offline broker when using bootstrap controller [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20497) ReadOnlyView implementations for wrapping stores
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20503) Integration tests for transaction buffering
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20504) Update state wipe tests
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20502) Integration tests for IQv2 transaction isolation
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20500) Transactional support for VersionedStores
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20501) Integration tests for IQv1 transaction isolation
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20491) Enforce transaction buffer memory limitstatestore.uncommitted.max.bytes
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20489) Add config to control state wipe behaviour
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20490) Generic transaction buffer framework
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20492) Factor out RocksDBStore iteration methods to DBAccessor
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20496) Interactive Query isolation level configuration and framework
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20494) Transactional support for InMemoryKeyValueStore
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20493) Transactional support for RocksDBStore
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20495) Transactional support for InMemorySessionStore and InMemoryWindowStore
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20506) kafka-configs.sh can't delete a nonexistent config from a offline broker when using bootstrap controller
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20505) Deadlock in KIP-932 share path: `SharePartition.rollbackOrProcessStateUpdates` completes future inside write lock, reenters `DelayedOperation` lock held by request handler
Travis Bischel (Jira)
-
[jira] [Created] (KAFKA-20505) Deadlock in KIP-932 share path: `SharePartition.rollbackOrProcessStateUpdates` completes future inside write lock, reenters `DelayedOperation` lock held by request handler
Travis Bischel (Jira)
-
[jira] [Commented] (KAFKA-20458) AcknowledgeType.RENEW re-delivers records to application via poll() in explicit acknowledgement mode, undocumented and inconsistent with broker-side contract
Andrew Schofield (Jira)
-
[PR] MINOR: Fix typos in comments (targetting, inital, comparision) [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20465) Adding transactional semantics to StateStores - implement KIP-892
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20504) Update state wipe tests
Nicholas Telford (Jira)
-
[jira] [Updated] (KAFKA-20499) InMemoryStores readOnly implementations
Nicholas Telford (Jira)
-
[jira] [Updated] (KAFKA-20498) RocksDBStore readOnly implementation
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20503) Integration tests for transaction buffering
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20502) Integration tests for IQv2 transaction isolation
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20501) Integration tests for IQv1 transaction isolation
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20500) Transactional support for VersionedStores
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20499) InMemoryStore readOnly implementations
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20498) RocksDBStore#readOnly implementation
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20497) ReadOnlyView implementations for wrapping stores
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20496) Interactive Query isolation level configuration and framework
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20495) Transactional support for InMemorySessionStore and InMemoryWindowStore
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20494) Transactional support for InMemoryKeyValueStore
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20493) Transactional support for RocksDBStore
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20492) Factor out RocksDBStore iteration methods to DBAccessor
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20491) Enforce transaction buffer memory limitstatestore.uncommitted.max.bytes
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20490) Generic transaction buffer framework
Nicholas Telford (Jira)
-
[jira] [Created] (KAFKA-20489) Add config to control state wipe behaviour
Nicholas Telford (Jira)
-
[jira] [Commented] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch
Michael Westerby (Jira)
-
[jira] [Deleted] (KAFKA-20483) KIP-892: Add unit tests for RocksDB transaction buffering
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20480) KIP-892: Update StreamTask and StandbyTask for isolation-level-aware error handling
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20481) KIP-892: Update TaskManager and task registry for isolation level
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20475) KIP-892: Update store adapters and suppliers for isolation level
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20482) KIP-892: Wire isolation level through KafkaStreams, StreamThread, and IQ
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20484) KIP-892: Add unit tests for task lifecycle and state manager transactional behavior
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20478) KIP-892: Update ProcessorStateManager for transactional commit/rollback
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20485) KIP-892: Add integration tests for KIP-892
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20469) KIP-892: Add transactional support to segmented stores
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20476) KIP-892: Add transactional interface compliance to in-memory stores
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20470) KIP-892: Add transactional support to headers-enabled segmented stores (KIP-1271)
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20472) KIP-892: Add approximateNumUncommittedBytes to StateStore API and WrappedStateStore
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20473) KIP-892: Wire uncommitted bytes through metered store wrappers and add metric
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20477) KIP-892: Add KIP-892 configuration to StreamsConfig
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20479) KIP-892: Add memory-pressure commit trigger to TaskExecutor
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20474) KIP-892: Add isolation awareness to caching wrappers
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20467) KIP-892: Add BatchedDBAccessor to RocksDBStore for write buffering
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20468) KIP-892: Add transactional support to RocksDBVersionedStore
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20466) KIP-892: Implement Generic Transaction Buffer (Phase 0)
Bill Bejeck (Jira)
-
Re: [PR] KAFKA-20292 [2/N]: Handle membership changes during offloaded streams assignments [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-19414) Remove Public APIs from 4.1, 4.2, 4.3
Mickael Maison (Jira)
-
[jira] [Updated] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch
Michael Westerby (Jira)
-
[jira] [Created] (KAFKA-20488) KRaft migration rollback causes offline partitions when KRaft epoch exceeds ZK controller epoch
Michael Westerby (Jira)
-
[PR] KAFKA-20464: Fix topology corruption when ConnectedStoreProviders share a StoreBuilder [kafka]
via GitHub
-
[PR] Upgrade checkstyle to 10.21.4 and fix Javadoc to prevent parsing errors [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-18905) Avoid out of order sequence errors from multiple in-flight batches
TengYao Chi (Jira)
-
[jira] [Commented] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology
chomingi (Jira)
-
[PR] introduce private method to remove clones [kafka]
via GitHub
-
[PR] KAFKA-18735: Return null from ConfigEntity.name() for default quotas [kafka]
via GitHub
-
[PR] Minor: Add DCL to improve performance [kafka]
via GitHub
-
[PR] MINOR: Move VerifiableProperties to server-common module [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20487) admin.listConfigResources only returns the groups having custom configs
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-20487) admin.listConfigResources only returns the groups having custom configs
Ming-Yen Chung (Jira)
-
[PR] KAFKA-20357: Persist lastProducerEpoch fields for the transaction log. [kafka]
via GitHub
-
[PR] MINOR: remove un-necessary integration tags [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20487) admin.listConfigResources only returns the groups having custom configs
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20487) admin.listConfigResources only returns the groups having custom configs
Chia-Ping Tsai (Jira)
-
[jira] [Updated] (KAFKA-20486) Include broker static configurations in BrokerRegistrationRequest
Chia-Ping Tsai (Jira)
-
[jira] [Created] (KAFKA-20486) Include broker static configurations in BrokerRegistrationRequest
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-20456: Don't throw on waitForFuture() futures and clean up leaked tasks [kafka]
via GitHub
-
[PR] KAFKA-20297 Move OperatingSystem, Java, Exit... into internal [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear
sanghyeok An (Jira)
-
[jira] [Updated] (KAFKA-17164) Consider to enforce application.server <server>:<port> format at config level
sanghyeok An (Jira)
-
[PR] KAFKA-20456: Bound waitForFuture() timeout to less than max.poll.interval [kafka]
via GitHub
-
[PR] MINOR: Cleanup TestUtils.scala [kafka]
via GitHub
-
[PR] MINOR: Bump setup-qemu-action, setup-buildx-action, and login-action [kafka]
via GitHub