Messages by Date
-
2026/08/24
[jira] [Updated] (KAFKA-20973) Unable to dynamically update non string configs with config providers
Chia-Ping Tsai (Jira)
-
2026/08/24
Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka]
via GitHub
-
2026/08/24
[jira] [Updated] (KAFKA-20980) Consider event-time-based record validity for Kafka Streams joins
sanghyeok An (Jira)
-
2026/08/24
Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Fix occasional OOM in FetcherTest [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Fix occasional OOM in FetcherTest [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-14922: Fail fast if application.id does not exist as consumer group in StreamsResetter [kafka]
via GitHub
-
2026/08/24
[jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor does not drop late records.
Kaspar Metsa (Jira)
-
2026/08/24
[PR] KAFKA-20979: Ensure indexes resize are fsynced when shutting down [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Cleanups in AlterConfigs [kafka]
via GitHub
-
2026/08/24
[PR] KAFKA-20955: Remove hamcrest from org.apache.kafka.streams.kstream.internals.graph package [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: bind only on loopback in SelectorTest/SslSelectorTest [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20976: Make max partitions per request configurable [kafka]
via GitHub
-
2026/08/24
[PR] MINOR: Fix IQ key hashing during streams-protocol rebalance [kafka]
via GitHub
-
2026/08/24
[jira] [Assigned] (KAFKA-19895) __consumer_offsets Partitions Growing to TB Size and Not Cleaning Until Broker Restart
md tanwir (Jira)
-
2026/08/24
[jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation
Mickael Maison (Jira)
-
2026/08/24
[jira] [Assigned] (KAFKA-18744) When I add sasl.login.callback.handler.class it is used for initial login but not used when ticket is about to expire
md tanwir (Jira)
-
2026/08/24
[jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation
Mickael Maison (Jira)
-
2026/08/24
[jira] [Updated] (KAFKA-20979) Potential data loss caused by time index truncation
Mickael Maison (Jira)
-
2026/08/24
Re: [PR] MINOR: bind only on loopback in SelectorTest/SslSelectorTest [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20850: Add system test for suppress() changelog across the HEADERS boundary [kafka]
via GitHub
-
2026/08/24
[jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation
Gaurav Narula (Jira)
-
2026/08/24
[jira] [Commented] (KAFKA-20979) Potential data loss caused by time index truncation
Luke Chen (Jira)
-
2026/08/24
Re: [PR] KAFKA-20850: Add system test for suppress() changelog across the HEADERS boundary [kafka]
via GitHub
-
2026/08/24
[jira] [Created] (KAFKA-20979) Potential data loss caused by time index truncation
Mickael Maison (Jira)
-
2026/08/24
Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: revert formatter test for latest testing metadata version [kafka]
via GitHub
-
2026/08/24
[jira] [Resolved] (KAFKA-20838) Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams initial rebalance delay
Ken Huang (Jira)
-
2026/08/24
Re: [PR] KAFKA-20838: Set initial rebalance delay to zero in IQv2StoreIntegrationTest [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Bump trunk to 4.5.0-SNAPSHOT [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20857: Use Java 25 in Docker images [kafka]
via GitHub
-
2026/08/24
[PR] minor: revert formatter test for latest testing metadata version [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Bump trunk to 4.5.0-SNAPSHOT [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka]
via GitHub
-
2026/08/24
Re: [PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka]
via GitHub
-
2026/08/24
[jira] [Updated] (KAFKA-20917) [Java-client] RecordAccumulator.ready performance regression
Kamal Chandraprakash (Jira)
-
2026/08/24
[jira] [Updated] (KAFKA-20917) [Java-client] RecordAccumulator.ready performance regression
Kamal Chandraprakash (Jira)
-
2026/08/24
Re: [PR] KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently [kafka]
via GitHub
-
2026/08/24
Re: [PR] KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently [kafka]
via GitHub
-
2026/08/23
[jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils
Shantanu Shukla (Jira)
-
2026/08/23
[PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Implement optional content size field in LZ4 frame header per LZ4 spec [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20941: Replace HTMLTestRunner with pytest-html [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20838: Set initial rebalance delay to zero in IQv2StoreIntegrationTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20954 Replace Hamcrest with JUnit assertions in foreign-key join tests [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20954 Remove hamcrest [kafka]
via GitHub
-
2026/08/23
[PR] KAFKA-20954 Remove hamcrest [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20689: Migrate reset integration tests to ClusterInstance [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka]
via GitHub
-
2026/08/23
[jira] [Assigned] (KAFKA-20954) Remove hamcrest from org.apache.kafka.streams.kstream.internals.foreignkeyjoin package
dino2895 (Jira)
-
2026/08/23
Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20786: Speed up TimeWindowedKStreamIntegrationTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] MM2: fail fast instead of silently resetting on data loss / topic reset. [kafka]
via GitHub
-
2026/08/23
[PR] MM2: fail fast instead of silently resetting on data loss / topic reset. [kafka]
via GitHub
-
2026/08/23
[PR] MINOR: Speed up TimestampedStoreUpgradeIntegrationTest [kafka]
via GitHub
-
2026/08/23
[jira] [Resolved] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON)
Chia-Ping Tsai (Jira)
-
2026/08/23
Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: update collaborator list [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka]
via GitHub
-
2026/08/23
[PR] MINOR: assert on sampled metric values in MetricsDuringTopicCreationDeletionTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: update collaborator list [kafka]
via GitHub
-
2026/08/23
[jira] [Updated] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments)
Avishek Das (Jira)
-
2026/08/23
[PR] MINOR: update collaborator list [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka]
via GitHub
-
2026/08/23
[jira] [Created] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py`
Chia-Ping Tsai (Jira)
-
2026/08/23
[jira] [Assigned] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py`
majialong (Jira)
-
2026/08/23
[jira] [Updated] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py`
Chia-Ping Tsai (Jira)
-
2026/08/23
[jira] [Updated] (KAFKA-20978) Add test case for consumer protocol to `benchmark_test.py`
Chia-Ping Tsai (Jira)
-
2026/08/23
Re: [PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka]
via GitHub
-
2026/08/23
[PR] MINOR: Fix missing % operator in assertion message in benchmark_test.py [kafka]
via GitHub
-
2026/08/23
[jira] [Created] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments)
Avishek Das (Jira)
-
2026/08/23
[jira] [Updated] (KAFKA-20977) RemoteCopyLagSegments/RemoteCopyLagBytes report a phantom lag of 1 on low-throughput partitions (single-record segments)
Avishek Das (Jira)
-
2026/08/23
[PR] KAFKA-20974: Update refresh_collaborators.py for committers.json [kafka]
via GitHub
-
2026/08/23
[PR] KAFKA-20977: Fix RemoteCopyLagSegments off-by-one on single-record segments [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20838: Set initial rebalance delay to zero in IQv2StoreIntegrationTest [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Simplify AlterPartitionManager request building and tests [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: fix ClientRebootstrapTest verification and admin cleanup [kafka]
via GitHub
-
2026/08/23
[jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership
Harsh Vasava (Jira)
-
2026/08/23
[jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership
Harsh Vasava (Jira)
-
2026/08/23
[jira] [Comment Edited] (KAFKA-20971) Add cross version system test for "streams" static group membership
Harsh Vasava (Jira)
-
2026/08/23
[jira] [Commented] (KAFKA-20971) Add cross version system test for "streams" static group membership
Harsh Vasava (Jira)
-
2026/08/23
Re: [PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka]
via GitHub
-
2026/08/23
Re: [PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka]
via GitHub
-
2026/08/23
[PR] KAFKA-20976: Make KRaft max partitions per request limit a config [kafka]
via GitHub
-
2026/08/23
[jira] [Updated] (KAFKA-20976) Make KRaft max partitions per request limit a config
Andrew Grant (Jira)
-
2026/08/23
Re: [PR] MINOR: Assert RequestConvertToJsonTest metrics against literal values [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Bump trunk to 4.5.0-SNAPSHOT [kafka]
via GitHub
-
2026/08/23
[PR] MINOR: Restore metadata version tests and add IBP_4_5_IV0 [kafka]
via GitHub
-
2026/08/23
[jira] [Updated] (KAFKA-20976) Make KRaft max partitions per request limit a config
Andrew Grant (Jira)
-
2026/08/23
[jira] [Commented] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON)
ASF GitHub Bot (Jira)
-
2026/08/23
[jira] [Created] (KAFKA-20976) Make KRaft max partitions per request limit a config
Andrew Grant (Jira)
-
2026/08/23
[jira] [Commented] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON)
ASF GitHub Bot (Jira)
-
2026/08/23
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/23
Re: [PR] MINOR: Bump trunk to 4.5.0-SNAPSHOT [kafka]
via GitHub
-
2026/08/22
[jira] [Commented] (KAFKA-20975) Remove hamcrest from streams test-utils
Shantanu Shukla (Jira)
-
2026/08/22
[jira] [Commented] (KAFKA-20948) Migrate hamcrest tests to JUnit
Shantanu Shukla (Jira)
-
2026/08/22
[jira] [Created] (KAFKA-20975) Remove hamcrest from streams test-utils
Shantanu Shukla (Jira)
-
2026/08/22
[PR] KAFKA-20975: Remove hamcrest from streams test-utils [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-8377: Materialize stateful KTable value transforms [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-20943 Develocity related Gradle plugin versions are updated [kafka]
via GitHub
-
2026/08/22
Re: [PR] jprnt02 [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-19048: Minimal movement replica balancing algorithm for reassignment [kafka]
via GitHub
-
2026/08/22
Re: [PR] MINOR: Note KS broker replication factor limitation [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-19762 Gradle feature for reproducible archives is turned *ON* [kafka]
via GitHub
-
2026/08/22
[jira] [Commented] (KAFKA-20906) Remove deprecated ValueJoinerWithKey overloads for stream-globalTable joins
Matthias J. Sax (Jira)
-
2026/08/22
[jira] [Commented] (KAFKA-20907) Remove deprecated 9-arg StreamsGroupDescription constructor
Matthias J. Sax (Jira)
-
2026/08/22
[PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in streams [kafka]
via GitHub
-
2026/08/22
[jira] [Created] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON)
Chia-Ping Tsai (Jira)
-
2026/08/22
Re: [PR] MINOR: Revert setup-gradle action to v5.0.2 [kafka]
via GitHub
-
2026/08/22
Re: [PR] MINOR: Revert setup-gradle action to v5.0.2 [kafka]
via GitHub
-
2026/08/22
[jira] [Assigned] (KAFKA-20974) Fix refresh_collaborators.py and committer file (JSON)
majialong (Jira)
-
2026/08/22
[jira] [Commented] (KAFKA-20901) [KRaft] cordoned.log.dirs is accepted but not enforced when log.dirs uses a relative path
majialong (Jira)
-
2026/08/22
[PR] KAFKA-20901: Enforce cordoned log directories configured with relative paths [kafka]
via GitHub
-
2026/08/22
[PR] MINOR: Revert setup-gradle action to v5.0.2 [kafka]
via GitHub
-
2026/08/22
[PR] KAFKA-14672 Accumulator queue time recording [kafka]
via GitHub
-
2026/08/22
[PR] KAFKA-17929: Handle spurious wakeups while awaiting processable tasks [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-19762 Gradle feature for reproducible archives is turned *ON* [kafka]
via GitHub
-
2026/08/22
Re: [PR] MINOR: Do not advertise describe APIs on the controller listener [kafka]
via GitHub
-
2026/08/22
[PR] MINOR: Do not advertise describe APIs on the controller listener [kafka]
via GitHub
-
2026/08/22
Re: [PR] KAFKA-20697: Add cross-version system tests for the streams rebalance protocol [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-6621: Updated Javadocs for UncaughtExceptionHandler in Kafka Streams [kafka]
via GitHub
-
2026/08/21
[jira] [Comment Edited] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Sree Varshini S (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Sree Varshini S (Jira)
-
2026/08/21
[PR] KAFKA-20455: wait for all producers to send startup_complete before executing system tests [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP] [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20970 Another busy loop happens if auto.commit.interval.ms is less than bootstrap.resolve.timeout.ms [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/21
[PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.4-IV2 for 4.4.0 [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20865: Do not unregister KRaft voter set members [kafka]
via GitHub
-
2026/08/21
[PR] KAFKA-15591: Reject out-of-order first produce request on empty partitions [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Assert RequestConvertToJsonTest metrics against literal values [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-6621: Updated Javadocs for UncaughtExceptionHandler in Kafka Streams [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: fix ClientRebootstrapTest verification and admin cleanup [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Use KafkaException instead of RuntimeException in admin result classes [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20965: Remove hamcrest from org.apache.kafka.streams.state.internals.metrics package [kafka]
via GitHub
-
2026/08/21
[PR] KAFKA-16158: Cleanup usage of `TimestampedBytesStore` interface [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20697: Add cross-version system tests for the streams rebalance protocol [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-18535) Flaky PlaintextConsumerPollTest.testMaxPollIntervalMsDelayInRevocation
Szymon Blumczynski (Jira)
-
2026/08/21
[jira] [Comment Edited] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash
Bill Bejeck (Jira)
-
2026/08/21
Re: [PR] KAFKA-19042 Move ProducerCompressionTest, ProducerFailureHandlingTest, and ProducerIdExpirationTest to client-integration-tests module [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20972: Change initializeState to take a single key [1/N] [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Lianet Magrans (Jira)
-
2026/08/21
Re: [PR] KAFKA-20448: Fix Docker JVM image build when using local kafka archive [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
[jira] [Comment Edited] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Sree Varshini S (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Sree Varshini S (Jira)
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20790: Follow up, avoid translation of assignmentconfig and make the output type unmodifiable [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash
Bill Bejeck (Jira)
-
2026/08/21
[PR] MINOR: Use KafkaException instead of RuntimeException in admin result classes [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently [kafka]
via GitHub
-
2026/08/21
[PR] MINOR: fix ClientRebootstrapTest verification and admin cleanup [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
-
2026/08/21
Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-19731) Remove AppInfoParser deprecated metrics
Sree Varshini S (Jira)
-
2026/08/21
Re: [PR] KAFKA-18915: Rewrite AdminClientRebootstrapTest to cover the current scenario [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-20966) RemoteLogInputStream can attempt an unbounded memory allocation when reading a corrupted remote log segment
sepuri sai krishna (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20907) Remove deprecated 9-arg StreamsGroupDescription constructor
Arnab Nandy (Jira)
-
2026/08/21
Re: [PR] KAFKA-19170 Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-20906) Remove deprecated ValueJoinerWithKey overloads for stream-globalTable joins
Arnab Nandy (Jira)
-
2026/08/21
[PR] KAFKA-16245: Improve reliability of short initialization timeout tests [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-20966) RemoteLogInputStream can attempt an unbounded memory allocation when reading a corrupted remote log segment
Bill Bejeck (Jira)
-
2026/08/21
Re: [PR] KAFKA-20850: Add system test for suppress() changelog across the HEADERS boundary [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: Improvements in test testComplexShareConsumer [kafka]
via GitHub
-
2026/08/21
[jira] [Updated] (KAFKA-20850) Add system test coverage for suppress() changelog upgrade/downgrade with dsl.store.format=HEADERS
Matthias J. Sax (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20850) Add system test coverage for suppress() changelog upgrade/downgrade with dsl.store.format=HEADERS
Matthias J. Sax (Jira)
-
2026/08/21
Re: [PR] KAFKA-20850: Add system test for suppress() changelog across the HEADERS boundary [kafka]
via GitHub
-
2026/08/21
[jira] [Commented] (KAFKA-17464) Flaky test: org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testWakeupAfterSyncGroupSentExternalCompletion
Szymon Blumczynski (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20462) ErrorHandlerContext does not provide access to original headers
Matthias J. Sax (Jira)
-
2026/08/21
[jira] [Commented] (KAFKA-20971) Add cross version system test for "streams" static group membership
Matthias J. Sax (Jira)
-
2026/08/21
Re: [PR] MINOR: update sandboxed-trivy-action version to latest approved version [kafka]
via GitHub
-
2026/08/21
Re: [PR] MINOR: update sandboxed-trivy-action version to latest approved version [kafka]
via GitHub