Skip to content

Commit f7593db

Browse files
authored
KAFKA-19666: Remove old restoration codepath from SmokeTestDriverIntegrationTest [3/N] (#20465)
clean up `SmokeTestDriverIntegrationTest` Reviewers: Lucas Brutschy <[email protected]>
1 parent b3eed51 commit f7593db

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -110,15 +110,12 @@ SmokeTestDriver.VerificationResult result() {
110110
// (1) 10 min timeout, (2) 30 tries of polling without getting any data
111111
@ParameterizedTest
112112
@CsvSource({
113-
"false, false, true",
114-
"true, false, true",
115-
"false, false, false",
116-
"true, false, false",
117-
"true, true, true",
118-
"true, true, false"
113+
"false, true",
114+
"false, false",
115+
"true, true",
116+
"true, false"
119117
})
120118
public void shouldWorkWithRebalance(
121-
final boolean stateUpdaterEnabled,
122119
final boolean processingThreadsEnabled,
123120
final boolean streamsProtocolEnabled
124121
) throws InterruptedException {
@@ -143,7 +140,6 @@ public void shouldWorkWithRebalance(
143140
final String appId = safeUniqueTestName(testInfo);
144141
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
145142
props.put(StreamsConfig.APPLICATION_ID_CONFIG, appId);
146-
props.put(InternalConfig.STATE_UPDATER_ENABLED, stateUpdaterEnabled);
147143
props.put(InternalConfig.PROCESSING_THREADS_ENABLED, processingThreadsEnabled);
148144
if (streamsProtocolEnabled) {
149145
props.put(StreamsConfig.GROUP_PROTOCOL_CONFIG, GroupProtocol.STREAMS.name().toLowerCase(Locale.getDefault()));

0 commit comments

Comments
 (0)