(kafka) branch trunk updated: KAFKA-19666: Remove old restoration codepath from EosIntegrationTest [5/N] (#20499)

[lucasbru]

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(