1.0.0-rc4

Author: wavejumper

project.clj

@@ -1,4 +1,4 @@
-(defproject io.factorhouse/kpow-streams-agent "1.0.0-rc3"
+(defproject io.factorhouse/kpow-streams-agent "1.0.0-rc4"
   :description "Kpow's Kafka Streams monitoring agent"
   :url "https://github.com/factorhouse/kpow-streams-agent"
   :license {:name         "Apache-2.0 License"
@@ -19,7 +19,7 @@
                    [:name "Derek Troy-West"]
                    [:url "https://factorhouse.io"]
                    [:roles
-                    [:role "developer"]
+                    [:role "developer"]7
                     [:role "maintainer"]]]])
   :dependencies [[org.clojure/clojure "1.12.0"]
                  [com.cognitect/transit-clj "1.0.333"]

src/clojure/io/factorhouse/kpow/agent.clj

@@ -156,6 +156,7 @@
                 :data           {:type  :observe/streams-agent
                                  :agent {:metrics-summary metrics-summary
                                          :id              agent-id
+                                         :captured        captured
                                          :version         "1.0.0"}}}
         record (ProducerRecord. (:topic snapshot-topic) taxon plan)]
     (.get (.send producer record))))
@@ -199,7 +200,8 @@
                   :producer       producer
                   :metrics-filter metrics-filter}]
       (doseq [[id [streams topology key-strategy]] @registered-topologies]
-        (try (when-let [next-ctx (snapshot-telemetry (assoc ctx :streams streams
+        (try (when-let [next-ctx (snapshot-telemetry (assoc ctx
+                                                            :streams streams
                                                             :topology topology
                                                             :key-strategy key-strategy
                                                             :agent-id id))]