Merge 7d021d7 into c3f4039

gojek · Jul 24, 2020 · 0453a23 · 0453a23
2 parents c3f4039 + 7d021d7
commit 0453a23
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/project.clj b/project.clj
@@ -25,7 +25,7 @@
                  [io.opentracing.contrib/opentracing-kafka-client "0.1.4" :exclusions [org.lz4/lz4-java com.github.luben/zstd-jni org.slf4j/slf4j-api org.xerial.snappy/snappy-java]]
                  [io.opentracing.contrib/opentracing-rabbitmq-client "0.1.5" :exclusions [com.rabbitmq/amqp-client]]
                  [org.apache.httpcomponents/fluent-hc "4.5.4"]
-                 [org.apache.kafka/kafka-streams "2.1.0" :exclusions [org.slf4j/slf4j-log4j12 log4j]]
+                 [org.apache.kafka/kafka-streams "2.3.0" :exclusions [org.slf4j/slf4j-log4j12 log4j]]
                  [org.apache.logging.log4j/log4j-core "2.12.1"]
                  [org.apache.logging.log4j/log4j-slf4j-impl "2.12.1"]
                  [org.clojure/clojure "1.10.0"]
@@ -65,13 +65,14 @@
                        :dependencies [[com.google.protobuf/protobuf-java "3.9.1"]
                                       [io.confluent/kafka-schema-registry "4.1.1" :exclusions [javax.ws.rs/javax.ws.rs-api com.fasterxml.jackson.core/jackson-annotations]]
                                       [junit/junit "4.12"]
-                                      [org.apache.kafka/kafka-streams "2.1.0" :classifier "test" :exclusions [org.slf4j/slf4j-log4j12 log4j]]
-                                      [org.apache.kafka/kafka-clients "2.1.0" :classifier "test"]
-                                      [org.apache.kafka/kafka_2.11 "2.1.0" :classifier "test"]
+                                      [org.apache.kafka/kafka-streams "2.3.0" :classifier "test" :exclusions [org.slf4j/slf4j-log4j12 log4j]]
+                                      [org.apache.kafka/kafka-clients "2.3.0" :classifier "test"]
+                                      [org.apache.kafka/kafka_2.11 "2.3.0" :classifier "test"]
                                       [org.clojure/test.check "0.10.0"]]
                        :plugins      [[lein-cloverage "1.0.13" :exclusions [org.clojure/clojure]]]
                        :repositories [["confluent-repo" "https://packages.confluent.io/maven/"]]}
-             :dev     {:plugins [[lein-cljfmt "0.6.4"]
+             :dev     {:plugins [[lein-ancient "0.6.15"]
+                                 [lein-cljfmt "0.6.4"]
                                  [lein-cloverage "1.0.13"]
                                  [lein-kibit "0.1.7" :exclusions [org.clojure/tools.cli rewrite-clj org.clojure/tools.reader]]]}
              :1.9     {:dependencies [[org.clojure/clojure "1.9.0"]]}

diff --git a/src/ziggurat/streams.clj b/src/ziggurat/streams.clj
@@ -114,7 +114,7 @@
   message)
 
 (defn store-supplier-builder []
-  (KeyValueStoreBuilder. (RocksDbKeyValueBytesStoreSupplier. "state-store")
+  (KeyValueStoreBuilder. (RocksDbKeyValueBytesStoreSupplier. "state-store" false)
                          (Serdes/ByteArray)
                          (Serdes/ByteArray)
                          (SystemTime.)))