Merge pull request #13 from smartcitiesdata/custom_kafka_version

support configured kafka version
UrbanOS-Public · Aug 22, 2019 · 632a143 · 632a143
2 parents f1dc0af + 71d270e
commit 632a143
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/divo_kafka.ex b/lib/divo_kafka.ex
@@ -18,6 +18,7 @@ defmodule DivoKafka do
     topics = Keyword.get(envars, :create_topics, "clusterready:1:1")
     host = Keyword.get(envars, :outside_host, "localhost")
     auto_create_topics = Keyword.get(envars, :auto_topic, true)
+    kafka_image_version = Keyword.get(envars, :kafka_image_version, "latest")
 
     check_topic =
       topics
@@ -36,7 +37,7 @@ defmodule DivoKafka do
         }
       },
       kafka: %{
-        image: "wurstmeister/kafka:latest",
+        image: "wurstmeister/kafka:#{kafka_image_version}",
         ports: ["9092:9092"],
         environment: [
           "KAFKA_AUTO_CREATE_TOPICS_ENABLE=#{auto_create_topics}",

diff --git a/mix.exs b/mix.exs
@@ -4,7 +4,7 @@ defmodule DivoKafka.MixProject do
   def project do
     [
       app: :divo_kafka,
-      version: "0.1.5",
+      version: "0.1.6",
       elixir: "~> 1.8",
       start_permanent: Mix.env() == :prod,
       deps: deps(),