tomstepp commented on code in PR #35812:
URL: https://github.com/apache/beam/pull/35812#discussion_r2260849466
##########
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java:
##########
@@ -1098,14 +1098,39 @@
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()}.
+ */
public Read<K, V> withAllowDuplicates(Boolean allowDuplicates) {
return toBuilder().setAllowDuplicates(allowDuplicates).build();
}
+ /**
+ * <p>Redistributes Kafka messages into a distinct number of keys for
processing in subsequent
+ * steps.
+ *
+ * <p>Specifying an explicit number of keys is generally receommended over
redistributing
Review Comment:
Fixed typo
--
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
