From ae42e96e55bb35d848d28f218c5949ce37d4925d Mon Sep 17 00:00:00 2001 From: Meher Mankikar Date: Fri, 16 Jun 2023 16:27:37 -0700 Subject: [PATCH] Fixing comment --- .../java/software/amazon/kinesis/config/KCLAppConfig.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java index 9dff8f74..081c7ef4 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/config/KCLAppConfig.java @@ -35,13 +35,12 @@ import java.util.Optional; /** * Default configuration for a producer or consumer used in integration tests. * Producer: puts records of size 60 KB at an interval of 100 ms - * Consumer: streaming configuration (vs polling) that starts processing records put on the shard 5 minutes before - * the start of the test + * Consumer: streaming configuration (vs polling) that starts processing records at shard horizon */ public abstract class KCLAppConfig { /** - * Name used for test stream and DDB table + * Name used for test stream and lease tracker table */ public abstract String getStreamName();