From 35caed02f40b00647840d8d7647d144b4b164af3 Mon Sep 17 00:00:00 2001
From: Jehan Bruggeman <jehan.bruggeman@euranova.eu>
Date: Wed, 22 May 2019 13:36:17 +0200
Subject: [PATCH] add :uris as a valid option for ConsumerGroup

---
 lib/kafka_ex/consumer_group.ex | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/lib/kafka_ex/consumer_group.ex b/lib/kafka_ex/consumer_group.ex
index 35bd6da1..54ab2eb3 100644
--- a/lib/kafka_ex/consumer_group.ex
+++ b/lib/kafka_ex/consumer_group.ex
@@ -94,6 +94,7 @@ defmodule KafkaEx.ConsumerGroup do
   * `:max_restarts`, `:max_seconds` - Supervisor restart policy parameters
   * `:partition_assignment_callback` - See
      `t:KafkaEx.ConsumerGroup.PartitionAssignment.callback/0`
+  * `:uris` - See `KafkaEx.create_worker/2`
 
   Note `:session_timeout` is registered with the broker and determines how long
   before the broker will de-register a consumer from which it has not heard a
@@ -111,6 +112,7 @@ defmodule KafkaEx.ConsumerGroup do
           | {:name, Supervisor.name()}
           | {:max_restarts, non_neg_integer}
           | {:max_seconds, non_neg_integer}
+          | {:uris, KafkaEx.uri()}
 
   @type options :: [option]