mjsax commented on code in PR #17973:
URL: https://github.com/apache/kafka/pull/17973#discussion_r1879003630
##########
streams/src/main/java/org/apache/kafka/streams/Topology.java:
##########
@@ -130,14 +133,34 @@ public synchronized Topology addSource(final String name,
* @param topics the name of one or more Kafka topics that this source is
to consume
* @return itself
* @throws TopologyException if processor is already added or if topics
have already been registered by another source
+ * @deprecated Since 4.0. Use {@link
#addSource(org.apache.kafka.streams.AutoOffsetReset, String, String...)}
instead.
*/
+ @Deprecated
public synchronized Topology addSource(final AutoOffsetReset offsetReset,
final String name,
final String... topics) {
internalTopologyBuilder.addSource(offsetReset, name, null, null, null,
topics);
return this;
}
+ /**
+ * Adds a new source that consumes the specified topics and forwards the
records to child processor and/or sink nodes.
+ * The source will use the specified {@link
org.apache.kafka.streams.AutoOffsetReset offset reset policy} if no committed
offsets are found.
+ *
+ * @param offsetReset the auto offset reset policy to use for this source
if no committed offsets are found
+ * @param name the unique name of the source used to reference this node
when {@link #addProcessor(String, ProcessorSupplier, String...) adding
processor children}
+ * @param topics the name of one or more Kafka topics that this source is
to consume
+ * @return itself
+ * @throws TopologyException if a processor is already added or if topics
have already been registered by another source
+ */
+ public synchronized Topology addSource(final
org.apache.kafka.streams.AutoOffsetReset offsetReset,
+ final String name,
+ final String... topics) {
+ // TODO mjsax
Review Comment:
Will fix this via https://github.com/apache/kafka/pull/18115 (similar below)
--
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]
