diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java index d051a1d2..3e4e931d 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java @@ -183,7 +183,7 @@ public class TestConsumer { this.consumerFuture = consumerExecutor.schedule(scheduler, 0, TimeUnit.SECONDS); } - public void stopProducer() { + private void stopProducer() { log.info("Cancelling producer and shutting down executor."); if (producerFuture != null) { producerFuture.cancel(false);