This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 709c5fab228 KAFKA-19666: Remove old restoration codepath from
EosIntegrationTest [5/N] (#20499)
709c5fab228 is described below
commit 709c5fab22834b3d4bda5ab37e63b566621f22c1
Author: Shashank <hsshashank.g...@gmail.com>
AuthorDate: Wed Sep 10 08:10:46 2025 -0700
KAFKA-19666: Remove old restoration codepath from EosIntegrationTest [5/N]
(#20499)
clean up `EosIntegrationTest.java`
Reviewers: Lucas Brutschy <lucas...@apache.org>
---
.../kafka/streams/integration/EosIntegrationTest.java | 15 +--------------
1 file changed, 1 insertion(+), 14 deletions(-)
diff --git
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
index 95c19fd9cb8..d8743330218 100644
---
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
+++
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
@@ -788,19 +788,8 @@ public class EosIntegrationTest {
@ParameterizedTest
@ValueSource(booleans = {true, false})
- public void
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterEnabled(
+ public void shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoring(
final boolean processingThreadsEnabled) throws Exception {
-
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoring(processingThreadsEnabled,
true);
- }
-
- @Test
- public void
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterDisabled()
throws Exception {
- shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoring(false,
false);
- }
-
- private void
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoring(
- final boolean processingThreadsEnabled,
- final boolean stateUpdaterEnabled) throws Exception {
final Properties streamsConfiguration = new Properties();
streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG,
applicationId);
@@ -812,7 +801,6 @@ public class EosIntegrationTest {
streamsConfiguration.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
"earliest");
streamsConfiguration.put(StreamsConfig.STATE_DIR_CONFIG,
TestUtils.tempDirectory(applicationId).getPath());
streamsConfiguration.put(InternalConfig.PROCESSING_THREADS_ENABLED,
processingThreadsEnabled);
- streamsConfiguration.put(InternalConfig.STATE_UPDATER_ENABLED,
stateUpdaterEnabled);
streamsConfiguration.put(StreamsConfig.restoreConsumerPrefix(ConsumerConfig.MAX_POLL_RECORDS_CONFIG),
100);
final String stateStoreName = "stateStore";
@@ -1223,7 +1211,6 @@ public class EosIntegrationTest {
properties.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
properties.put(StreamsConfig.STATE_DIR_CONFIG, stateTmpDir + appDir);
properties.put(StreamsConfig.APPLICATION_SERVER_CONFIG, dummyHostName
+ ":2142");
- properties.put(InternalConfig.STATE_UPDATER_ENABLED,
processingThreadsEnabled);
properties.put(InternalConfig.PROCESSING_THREADS_ENABLED,
processingThreadsEnabled);
final Properties config = StreamsTestUtils.getStreamsConfig(
