Fix unit tests

factorhouse · May 27, 2022 · 6287882 · 6287882
1 parent 894a036
commit 6287882
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/test/io/operatr/agent_test.clj b/test/io/operatr/agent_test.clj
@@ -15,8 +15,13 @@
     props))
 
 (deftest filter-props
-  (is (empty? (StreamsRegistry/filterProperties (->props {"fo" "bar"}))))
-  (is (= {"bootstrap.servers" "xyz"}
+  (is (= {"compression.type" "gzip"}
+         (StreamsRegistry/filterProperties (->props {"fo" "bar"}))))
+  (is (= {"bootstrap.servers" "xyz"
+          "compression.type"  "lz4"}
+         (into {} (StreamsRegistry/filterProperties (->props {"compression.type" "lz4" "bootstrap.servers" "xyz"})))))
+  (is (= {"bootstrap.servers" "xyz"
+          "compression.type"  "gzip"}
          (into {} (StreamsRegistry/filterProperties (->props {"fo" "bar" "bootstrap.servers" "xyz"}))))))
 
 (defn ^Topology test-topology