antssilva96 commented on code in PR #140:
URL:
https://github.com/apache/flink-connector-aws/pull/140#discussion_r1592721925
##########
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java:
##########
@@ -320,12 +320,35 @@ public enum EFORegistrationType {
public static final String EFO_HTTP_CLIENT_READ_TIMEOUT_MILLIS =
"flink.stream.efo.http-client.read-timeout";
+ /**
+ * Flag to configure whether {@link #STREAM_INITIAL_POSITION} should be
considered for new
+ * streams, when the app is already consuming from other streams.
+ */
+ public static final String APPLY_STREAM_INITIAL_POSITION_FOR_NEW_STREAMS =
+ "flink.stream.initpos-for-new-streams";
+
+ /**
+ * Property that can be used to ignore the restore state for a particular
stream and instead use
+ * the initial position. This is useful to reset a specific stream to
consume from TRIM_HORIZON
+ * or LATEST if needed. Values must be passed in a comma separated list.
+ *
+ * <p>If a stream is in this list, it will use initial position regardless
of the value of the
+ * {@link #APPLY_STREAM_INITIAL_POSITION_FOR_NEW_STREAMS} property.
+ */
+ public static final String STREAMS_TO_APPLY_STREAM_INITIAL_POSITION_TO =
+ "flink.stream.initpos-streams";
+
Review Comment:
not really sure about these property names... any suggestions ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
