org.apache.kafka.streams.processor.TopologyBuilder / org.apache.kafka.streams.kstream.KStreamBuilder对象是否可重用？
我想提供使用完全相同的配置重新启动给定的kafka流应用程序的功能。
到目前为止，以下代码一直在工作，但是我在文档中找不到任何确凿的确认：
TopologyBuilder topology = ...
Properties properties = ...
// first time
KafkaStreams handle1 = new KafkaStreams(topology, properties);
handle1.start()
...
handle1.stop()
// second time
KafkaStreams handle2 = new KafkaStreams(topology, properties); // <- is this safe?
handle2.start()
最佳答案
是的，它们是可重用的，并且您所做的绝对安全。