|
|
|
@ -41,6 +41,7 @@ import org.apache.kafka.streams.kstream.Materialized;
@@ -41,6 +41,7 @@ import org.apache.kafka.streams.kstream.Materialized;
|
|
|
|
|
import org.apache.kafka.streams.kstream.Produced; |
|
|
|
|
import org.apache.kafka.streams.state.KeyValueStore; |
|
|
|
|
import org.apache.kafka.test.IntegrationTest; |
|
|
|
|
import org.apache.kafka.test.TestUtils; |
|
|
|
|
import org.junit.ClassRule; |
|
|
|
|
import org.junit.Test; |
|
|
|
|
import org.junit.experimental.categories.Category; |
|
|
|
@ -141,7 +142,8 @@ public class SuppressionDurabilityIntegrationTest {
@@ -141,7 +142,8 @@ public class SuppressionDurabilityIntegrationTest {
|
|
|
|
|
mkEntry(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers()), |
|
|
|
|
mkEntry(StreamsConfig.POLL_MS_CONFIG, Integer.toString(COMMIT_INTERVAL)), |
|
|
|
|
mkEntry(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, Integer.toString(COMMIT_INTERVAL)), |
|
|
|
|
mkEntry(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, eosEnabled ? EXACTLY_ONCE : AT_LEAST_ONCE) |
|
|
|
|
mkEntry(StreamsConfig.PROCESSING_GUARANTEE_CONFIG, eosEnabled ? EXACTLY_ONCE : AT_LEAST_ONCE), |
|
|
|
|
mkEntry(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath()) |
|
|
|
|
)); |
|
|
|
|
|
|
|
|
|
KafkaStreams driver = getStartedStreams(streamsConfig, builder, true); |
|
|
|
|