root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-19666: Remove old restoration codepath from SmokeTestDriverIntegrationTest [3/N] (#20465) 

clean up `SmokeTestDriverIntegrationTest`

Reviewers: Lucas Brutschy <lucasbru@apache.org>
This commit is contained in:
Shashank 2025-09-08 08:48:37 -07:00 committed by GitHub
parent b3eed51023
commit f7593db287
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -110,15 +110,12 @@ public class SmokeTestDriverIntegrationTest {
// (1) 10 min timeout, (2) 30 tries of polling without getting any data // (1) 10 min timeout, (2) 30 tries of polling without getting any data
@ParameterizedTest @ParameterizedTest
@CsvSource({ @CsvSource({
"false, false, true", "false, true",
"true, false, true", "false, false",
"false, false, false", "true, true",
"true, false, false", "true, false"
"true, true, true",
"true, true, false"
}) })
public void shouldWorkWithRebalance( public void shouldWorkWithRebalance(
final boolean stateUpdaterEnabled,
final boolean processingThreadsEnabled, final boolean processingThreadsEnabled,
final boolean streamsProtocolEnabled final boolean streamsProtocolEnabled
) throws InterruptedException { ) throws InterruptedException {
@ -143,7 +140,6 @@ public class SmokeTestDriverIntegrationTest {
final String appId = safeUniqueTestName(testInfo); final String appId = safeUniqueTestName(testInfo);
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(StreamsConfig.APPLICATION_ID_CONFIG, appId); props.put(StreamsConfig.APPLICATION_ID_CONFIG, appId);
props.put(InternalConfig.STATE_UPDATER_ENABLED, stateUpdaterEnabled);
props.put(InternalConfig.PROCESSING_THREADS_ENABLED, processingThreadsEnabled); props.put(InternalConfig.PROCESSING_THREADS_ENABLED, processingThreadsEnabled);
if (streamsProtocolEnabled) { if (streamsProtocolEnabled) {
props.put(StreamsConfig.GROUP_PROTOCOL_CONFIG, GroupProtocol.STREAMS.name().toLowerCase(Locale.getDefault())); props.put(StreamsConfig.GROUP_PROTOCOL_CONFIG, GroupProtocol.STREAMS.name().toLowerCase(Locale.getDefault()));