Addition of properties

gojek · Mar 2, 2021 · 7cbce8e · 7cbce8e
1 parent a6e79cc
commit 7cbce8e
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/experiment_scripts/zookeeper_access_disable.sh b/experiment_scripts/zookeeper_access_disable.sh
@@ -6,8 +6,8 @@ container_id=`docker ps -aqf "name=ziggurat_kafka${brokerid}_1"`
 
 echo "Disabling zookeeper access on broker kafka${brokerid}"
 
-docker exec -it  $container_id /bin/bash -c  "apt-get update && apt-get install -y iptables && iptables -A INPUT -s ziggurat_zookeeper_1.ziggurat_default -j DROP"
-
+#docker exec -it  $container_id /bin/bash -c  "apt-get update && apt-get install -y iptables && iptables -A INPUT -s ziggurat_zookeeper_1.ziggurat_default -j DROP"
+docker exec -it  $container_id /bin/bash -c  "iptables -A INPUT -s ziggurat_zookeeper_1.ziggurat_default -j DROP"
 
 
 

diff --git a/project.clj b/project.clj
@@ -1,4 +1,4 @@
-(defproject tech.gojek/ziggurat "3.9.0"
+(defproject tech.gojek/ziggurat "3.9.0-alpha"
   :description "A stream processing framework to build stateless applications on kafka"
   :url "https://github.com/gojektech/ziggurat"
   :license {:name "Apache License, Version 2.0"

diff --git a/src/ziggurat/streams.clj b/src/ziggurat/streams.clj
@@ -33,6 +33,8 @@
    :oldest-processed-message-in-s      604800
    :changelog-topic-replication-factor 3
    :default-api-timeout-ms-config      60000
+   :retries                             10
+   :retry-backoff-ms                   60000
    :session-timeout-ms-config          10000
    :consumer-type                      :default
    :default-key-serde                  "org.apache.kafka.common.serialization.Serdes$ByteArraySerde"
@@ -79,7 +81,9 @@
                            value-deserializer-encoding
                            deserializer-encoding
                            session-timeout-ms-config
-                           default-api-timeout-ms-config]}]
+                           default-api-timeout-ms-config
+                           retries
+                           retry-backoff-ms]}]
   (validate-auto-offset-reset-config auto-offset-reset-config)
   (doto (Properties.)
     (.put StreamsConfig/APPLICATION_ID_CONFIG application-id)
@@ -93,6 +97,8 @@
     (.put StreamsConfig/REPLICATION_FACTOR_CONFIG (int changelog-topic-replication-factor))
     (.put ConsumerConfig/AUTO_OFFSET_RESET_CONFIG auto-offset-reset-config)
     (.put ConsumerConfig/SESSION_TIMEOUT_MS_CONFIG (int session-timeout-ms-config))
+    (.put StreamsConfig/RETRIES_CONFIG (int retries))
+    (.put StreamsConfig/RETRY_BACKOFF_MS_CONFIG (int retry-backoff-ms))
     (.put ConsumerConfig/DEFAULT_API_TIMEOUT_MS_CONFIG (int default-api-timeout-ms-config))
     (set-upgrade-from-config upgrade-from)
     (set-encoding-config key-deserializer-encoding value-deserializer-encoding deserializer-encoding)))