Messages by Thread
-
[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
-
[jira] [Commented] (KAFKA-20170) Support topology updates for streams groups without requiring a new group
sanghyeok An (Jira)
-
[jira] [Assigned] (KAFKA-20170) Support topology updates for streams groups without requiring a new group
sanghyeok An (Jira)
-
[jira] [Commented] (KAFKA-20463) Merging a PR in kafka-site does not update the website
ASF GitHub Bot (Jira)
-
Re: [PR] Refactor code to avoid discovery conflicts for classes:{Supported|Finalized}VersionRange [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-14588) Move ConfigCommand to tools
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset
Daeho Kwon (Jira)
-
[PR] KAFKA-20452: Avoid creating unnecessary empty batches in LogCleaner below the High Watermark [kafka]
via GitHub
-
[PR] MINOR: Remove commonsLang (#21115) [kafka]
via GitHub
-
[jira] (KAFKA-20454) Verify that `bin/kafka-consumer-groups.sh --reset-offsets` fails for "streams" group
Szabolcs Stremler (Jira)
-
[PR] KAFKA-20454: Prevent offset reset for streams groups in kafka-consumer-groups.sh [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20280) DLQ not supported for ProductionExceptionHander on global thread
Matthias J. Sax (Jira)
-
Re: [PR] KAFKA-19979: Improve Kafka Streams config files [kafka]
via GitHub
-
[PR] MINOR: Integration test for demo of restoration race condition [kafka]
via GitHub
-
[PR] KAFKA-20456: Use lighter options for RocksDB offsets column family [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20422) Add DSL integration tests for header stores with explicit suppliers
Matthias J. Sax (Jira)
-
[PR] MINOR: add DCL on get or create meter for performance improvement [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20484) KIP-892: Add unit tests for task lifecycle and state manager transactional behavior
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20485) KIP-892: Add integration tests for KIP-892
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20481) KIP-892: Update TaskManager and task registry for isolation level
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20483) KIP-892: Add unit tests for RocksDB transaction buffering
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20482) KIP-892: Wire isolation level through KafkaStreams, StreamThread, and IQ
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20478) KIP-892: Update ProcessorStateManager for transactional commit/rollback
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20480) KIP-892: Update StreamTask and StandbyTask for isolation-level-aware error handling
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20477) KIP-892: Add KIP-892 configuration to StreamsConfig
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20479) KIP-892: Add memory-pressure commit trigger to TaskExecutor
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20476) KIP-892: Add transactional interface compliance to in-memory stores
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20474) KIP-892: Add isolation awareness to caching wrappers
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20475) KIP-892: Update store adapters and suppliers for isolation level
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20473) KIP-892: Wire uncommitted bytes through metered store wrappers and add metric
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20470) KIP-892: Add transactional support to headers-enabled segmented stores (KIP-1271)
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20472) KIP-892: Add approximateNumUncommittedBytes to StateStore API and WrappedStateStore
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20469) KIP-892: Add transactional support to segmented stores
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20468) KIP-892: Add transactional support to RocksDBVersionedStore
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20466) KIP-892: Implement Generic Transaction Buffer (Phase 0)
Bill Bejeck (Jira)
-
[jira] [Assigned] (KAFKA-20467) KIP-892: Add BatchedDBAccessor to RocksDBStore for write buffering
Bill Bejeck (Jira)
-
[jira] [Resolved] (KAFKA-20373) CVE-2025-67030 in plexus-utils-3.5.1.jar
Mickael Maison (Jira)
-
[jira] [Resolved] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported
Lianet Magrans (Jira)
-
[jira] [Commented] (KAFKA-20465) Adding transactional semantics to StateStores - implement KIP-892
Shekhar Prasad Rajak (Jira)
-
[jira] [Created] (KAFKA-20484) KIP-892: Add unit tests for task lifecycle and state manager transactional behavior
Bill Bejeck (Jira)
-
[jira] [Deleted] (KAFKA-20471) KIP-892: Implement Generic Transaction Buffer (Phase 0)
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20485) KIP-892: Add integration tests for KIP-892
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20482) KIP-892: Wire isolation level through KafkaStreams, StreamThread, and IQ
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20483) KIP-892: Add unit tests for RocksDB transaction buffering
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20478) KIP-892: Update ProcessorStateManager for transactional commit/rollback
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20479) KIP-892: Add memory-pressure commit trigger to TaskExecutor
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20481) KIP-892: Update TaskManager and task registry for isolation level
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20480) KIP-892: Update StreamTask and StandbyTask for isolation-level-aware error handling
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20477) KIP-892: Add KIP-892 configuration to StreamsConfig
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20476) KIP-892: Add transactional interface compliance to in-memory stores
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20473) KIP-892: Wire uncommitted bytes through metered store wrappers and add metric
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20474) KIP-892: Add isolation awareness to caching wrappers
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20475) KIP-892: Update store adapters and suppliers for isolation level
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20471) KIP-892: Implement Generic Transaction Buffer (Phase 0)
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20472) KIP-892: Add approximateNumUncommittedBytes to StateStore API and WrappedStateStore
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20470) KIP-892: Add transactional support to headers-enabled segmented stores (KIP-1271)
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20468) KIP-892: Add transactional support to RocksDBVersionedStore
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20469) KIP-892: Add transactional support to segmented stores
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20467) KIP-892: Add BatchedDBAccessor to RocksDBStore for write buffering
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20466) KIP-892: Implement Generic Transaction Buffer (Phase 0)
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20417) Create integration tests for KIP-1035 changes
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20465) Adding transactional semantics to StateStores - implement KIP-892
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20465) Implement KIP-892
Bill Bejeck (Jira)
-
[jira] [Created] (KAFKA-20465) Implement KIP-892
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to something newer
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-20456) Task not found in StateUpdater throwing an exception and causing unnecessary restoration
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Lianet Magrans (Jira)
-
Re: [PR] KAFKA-17430: Move RequestChannel.Metrics/RequestMetrics to server module [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20456) Task not found in StateUpdater throwing an exception and causing unnecessary retoration
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology
Stef Noten (Jira)
-
[jira] [Created] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology
Stef Noten (Jira)
-
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20416) RocksDB loses entries during broker patches.
Bill Bejeck (Jira)
-
[PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka]
via GitHub
-
[PR] Add Mini HTTP Client - Kafka design patterns learning project [kafka]
via GitHub
-
[PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20463) Merging a PR in kafka-site does not update the website
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-20462) ErrorHandlerContext does not provide access to original headers
Philipp Schirmer (Jira)
-
[jira] [Created] (KAFKA-20462) ErrorHandlerContext does not provide access to original headers
Philipp Schirmer (Jira)