diff --git a/ksqldb-rest-app/src/test/java/io/confluent/ksql/api/integration/ScalablePushBandwidthThrottleIntegrationTest.java b/ksqldb-rest-app/src/test/java/io/confluent/ksql/api/integration/ScalablePushBandwidthThrottleIntegrationTest.java index c5abb3b1cca7..95411b3488fe 100644 --- a/ksqldb-rest-app/src/test/java/io/confluent/ksql/api/integration/ScalablePushBandwidthThrottleIntegrationTest.java +++ b/ksqldb-rest-app/src/test/java/io/confluent/ksql/api/integration/ScalablePushBandwidthThrottleIntegrationTest.java @@ -88,6 +88,7 @@ public class ScalablePushBandwidthThrottleIntegrationTest { .withProperties(ClientTrustStore.trustStoreProps()) .withProperty(KSQL_QUERY_PUSH_SCALABLE_ENABLED , true) .withProperty(KSQL_QUERY_PUSH_SCALABLE_MAX_HOURLY_BANDWIDTH_MEGABYTES_CONFIG , 1) + .withProperty("auto.offset.reset", "latest") .withProperty(KSQL_STREAMS_PREFIX + StreamsConfig.NUM_STREAM_THREADS_CONFIG, 1) .withProperty(KSQL_DEFAULT_KEY_FORMAT_CONFIG, "JSON") .build();