Deprecate io.operatr.kpow.StreamsRegistry

README.md

@@ -191,11 +191,12 @@ If you have set a UI-friendly cluster name using the `ENVIRONMENT_NAME` environm
 
 ```java
 
-import io.factorhouse.kpow.key.ManualKeyStrategy;
 
 // This sets a manual key of `Trade Book (Staging)`, the name of the clusters environment name in Kpow's UI.
 KeyStrategy keyStrategy = new ManualKeyStrategy("Trade Book (Staging)");
-registry.register(streams, topology, keyStrategy);
+registry.
+
+        register(streams, topology, keyStrategy);
 ```
 
 ### Minimum Required ACLs

src/java/io/operatr/kpow/StreamsRegistry.java

@@ -3,6 +3,7 @@
 import clojure.java.api.Clojure;
 import clojure.lang.IFn;
 import io.factorhouse.kpow.MetricFilter;
+import io.factorhouse.kpow.key.KeyStrategy;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.common.serialization.Serializer;
 import org.apache.kafka.streams.KafkaStreams;
@@ -11,6 +12,12 @@
 import java.util.ArrayList;
 import java.util.Properties;
 
+
+/**
+ * @deprecated This class is no longer recommended for use.
+ * Please use {@link io.factorhouse.kpow.StreamsRegistry} instead.
+ */
+@Deprecated
 public class StreamsRegistry implements AutoCloseable {
 
     public static class StreamsAgent {
@@ -91,11 +98,11 @@ public StreamsRegistry(Properties props) {
         this(props, MetricFilter.defaultMetricFilter());
     }
 
-    public StreamsAgent register(KafkaStreams streams, Topology topology) {
+    public StreamsAgent register(KafkaStreams streams, Topology topology, KeyStrategy keyStrategy) {
         IFn require = Clojure.var("clojure.core", "require");
         require.invoke(Clojure.read("io.factorhouse.kpow.agent"));
         IFn registerFn = Clojure.var("io.factorhouse.kpow.agent", "register");
-        String id = (String) registerFn.invoke(agent, streams, topology);
+        String id = (String) registerFn.invoke(agent, streams, topology, keyStrategy);
         if (id != null) {
             return new StreamsAgent(id);
         } else {