import io.operatr.kpow.StreamsRegistry;
// Your Kafka Streams topology
Topology topology = createMyTopology();
// Your Kafka Streams config
Properties props = new createMyStreamProperties();
// Your Kafka Streams instance
KafkaStreams streams = new KafkaStreams(topology, props);
// Create a kPow StreamsRegistry
StreamsRegistry registry = new StreamsRegistry(props);
// Register your KafkaStreams and Topology instances with the StreamsRegistry
registry.register(streams, topology);
// Start your Kafka Streams application