tomstepp commented on code in PR #35812:
URL: https://github.com/apache/beam/pull/35812#discussion_r2260848217
##########
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java:
##########
@@ -1098,14 +1098,39 @@ public Read<K, V> withRedistribute() {
return toBuilder().setRedistributed(true).build();
}
+ /**
+ * <p>Hints to the runner that it can relax exactly-once processing
guarantees, allowing
+ * duplicates in at-least-once processing mode of Kafka inputs.
+ *
+ * <p>Must be used with {@link KafkaIO#withRedistribute()}.
+ *
+ * <p>Not compatible with {@link KafkaIO#withOffsetDeduplication()}.
Review Comment:
Added param and return comments.
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
