Skip to content

Commit af09bdd

Browse files
committed
Make sure the broker list is an array
1 parent 81f2476 commit af09bdd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

examples/simple-consumer.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
# with e.g. `$stderr` if you want to see what's happening under the hood.
1515
logger = Logger.new(StringIO.new)
1616

17-
brokers = ENV.fetch("KAFKA_BROKERS")
17+
brokers = ENV.fetch("KAFKA_BROKERS").split(",")
1818

1919
# Make sure to create this topic in your Kafka cluster or configure the
2020
# cluster to auto-create topics.

0 commit comments

Comments
 (0)