diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/BasicStreamConsumerIntegrationTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/BasicStreamConsumerIntegrationTest.java index cd1ed524..457c4dbf 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/BasicStreamConsumerIntegrationTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/BasicStreamConsumerIntegrationTest.java @@ -16,17 +16,17 @@ public class BasicStreamConsumerIntegrationTest { consumer.run(); } -// @Test -// public void kclReleaseCanaryPollingH1Test() throws Exception { -// KCLAppConfig consumerConfig = new ReleaseCanaryPollingH1TestConfig(); -// TestConsumer consumer = new TestConsumer(consumerConfig); -// consumer.run(); -// } -// -// @Test -// public void kclReleaseCanaryStreamingTest() throws Exception { -// KCLAppConfig consumerConfig = new ReleaseCanaryStreamingTestConfig(); -// TestConsumer consumer = new TestConsumer(consumerConfig); -// consumer.run(); -// } + @Test + public void kclReleaseCanaryPollingH1Test() throws Exception { + KCLAppConfig consumerConfig = new ReleaseCanaryPollingH1TestConfig(); + TestConsumer consumer = new TestConsumer(consumerConfig); + consumer.run(); + } + + @Test + public void kclReleaseCanaryStreamingTest() throws Exception { + KCLAppConfig consumerConfig = new ReleaseCanaryStreamingTestConfig(); + TestConsumer consumer = new TestConsumer(consumerConfig); + consumer.run(); + } }