combine all config.test*edn files

Makefile

@@ -11,8 +11,9 @@ setup:
 	sleep 10
 	docker exec ziggurat_kafka /opt/bitnami/kafka/bin/kafka-topics.sh --create --topic $(topic) --partitions 3 --replication-factor 1 --zookeeper ziggurat_zookeeper
 	docker exec ziggurat_kafka /opt/bitnami/kafka/bin/kafka-topics.sh --create --topic $(another_test_topic) --partitions 3 --replication-factor 1 --zookeeper ziggurat_zookeeper
+
 test: setup
-	ZIGGURAT_STREAM_ROUTER_DEFAULT_ORIGIN_TOPIC=$(topic) lein test
+	TESTING_TYPE=local lein test
 	docker-compose down
 
 setup-cluster:
@@ -24,10 +25,12 @@ setup-cluster:
 # 	Sleeping for 30s to allow the cluster to come up
 	docker exec ziggurat_kafka1_1 kafka-topics --create --topic $(topic) --partitions 3 --replication-factor 3 --if-not-exists --zookeeper ziggurat_zookeeper_1
 	docker exec ziggurat_kafka1_1 kafka-topics --create --topic $(another_test_topic) --partitions 3 --replication-factor 3 --if-not-exists --zookeeper ziggurat_zookeeper_1
+
 test-cluster: setup-cluster
-	ZIGGURAT_STREAM_ROUTER_DEFAULT_ORIGIN_TOPIC=$(topic) lein test-cluster
+	TESTING_TYPE=cluster lein test
 	docker-compose -f docker-compose-cluster.yml down
 	rm -rf /tmp/ziggurat_kafka_cluster_data
+
 coverage: setup
 	lein code-coverage
 	docker-compose down

README.md

@@ -488,7 +488,7 @@ All Ziggurat configs should be in your `clonfig` `config.edn` under the `:ziggur
                                                                        :key-serializer                        "org.apache.kafka.common.serialization.StringSerializer"}}}
             :enable-streams-uncaught-exception-handling [true :bool]
             :default-api-timeout-ms-config [600000 :int]
-            :datadog              {:host    "localhost"
+            :statsd               {:host    "localhost"
                                    :port    [8125 :int]
                                    :enabled [false :bool]}
             :statsd               {:host    "localhost"
@@ -543,8 +543,7 @@ All Ziggurat configs should be in your `clonfig` `config.edn` under the `:ziggur
       - max.in.flight.requests.per.connection - The maximum number of unacknowledged requests the client will send on a single connection before blocking.
       - enable.idempotence - When set to 'true', the producer will ensure that exactly one copy of each message is written in the stream. If 'false', producer retries due to broker failures, etc., may write duplicates of the retried message in the stream.
 
-- datadog - The statsd host and port that metrics should be sent to, although the key name is datadog, it supports statsd as well to send metrics.
-- statsd - Same as datadog but with a more appropriate name, the :datadog key will be deprecated in the future.
+- statsd - Formerly known as datadog, The statsd host and port that metrics should be sent to.
 - sentry - Whenever a :failure keyword is returned from the mapper-function or an exception is raised while executing the mapper-function, an event is sent to sentry. You can skip this flow by disabling it.
 - rabbit-mq-connection - The details required to make a connection to rabbitmq. We use rabbitmq for the retry mechanism.
 - rabbit-mq - The queues that are part of the retry mechanism
@@ -596,9 +595,6 @@ and different timeout values.
 
 ## Deprecation Notice
 
-- Please note that the :datadog key inside the config file will be removed (sometime in the future) in favor of :statsd. Both contents are same though, it's just the key name was changed.
-  The reason for this is to avoid confusion with our users. We would still have backward compatibility for the :datadog key.
-
 ## Contribution
 
 - For dev setup and contributions please refer to CONTRIBUTING.md

bin/run_cluster_tests_in_ci.sh

@@ -3,5 +3,4 @@
 set -ex
 
 lein clean
-mv -fv resources/config.test.{cluster.ci.edn,cluster.edn}
 sudo make test-cluster

project.clj

@@ -61,9 +61,7 @@
   :plugins [[lein-shell "0.5.0"]]
   :pedantic? :warn
   :java-source-paths ["src/com"]
-  :aliases {"code-coverage" ["with-profile" "test" "cloverage" "--output" "coverage" "--lcov"]
-            "test-cluster"  ["shell" "lein" "test"]}
-  :shell {:env {"TEST_CONFIG_FILE" "config.test.cluster.edn"}}
+  :aliases {"code-coverage" ["with-profile" "test" "cloverage" "--output" "coverage" "--lcov"]}
   :aot [ziggurat.kafka-consumer.invalid-return-type-exception]
   :profiles {:uberjar {:aot         :all
                        :global-vars {*warn-on-reflection* true}