ableegoldman commented on a change in pull request #10683:
URL: https://github.com/apache/kafka/pull/10683#discussion_r669188996
##########
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##########
@@ -799,41 +795,41 @@ public KafkaStreams(final Topology topology,
public KafkaStreams(final Topology topology,
final StreamsConfig config,
final Time time) {
- this(topology.internalTopologyBuilder, config, new
DefaultKafkaClientSupplier(), time);
+ this(new TopologyMetadata(topology.internalTopologyBuilder, config),
config, new DefaultKafkaClientSupplier(), time);
}
- private KafkaStreams(final InternalTopologyBuilder internalTopologyBuilder,
- final StreamsConfig config,
- final KafkaClientSupplier clientSupplier) throws
StreamsException {
- this(internalTopologyBuilder, config, clientSupplier, Time.SYSTEM);
- }
-
- private KafkaStreams(final InternalTopologyBuilder internalTopologyBuilder,
+ private KafkaStreams(final Topology topology,
final StreamsConfig config,
final KafkaClientSupplier clientSupplier,
final Time time) throws StreamsException {
+ this(new TopologyMetadata(topology.internalTopologyBuilder, config),
config, clientSupplier, time);
+ }
+
+ protected KafkaStreams(final TopologyMetadata topologyMetadata,
Review comment:
Just this one does, as it's called from the child class
KafkaStreamsNamedTopologyWrapper. I'll change the one below back to private
though
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
