From 0bdff4e833f73518a7219fca04dfbc3ed201b06e Mon Sep 17 00:00:00 2001 From: Marc Labbe Date: Thu, 14 Nov 2013 09:26:49 -0500 Subject: Allow KafkaClient to take in a list of brokers for bootstrapping --- example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'example.py') diff --git a/example.py b/example.py index 3a2dc92..0cf5583 100644 --- a/example.py +++ b/example.py @@ -14,7 +14,7 @@ def consume_example(client): print(message) def main(): - client = KafkaClient("localhost", 9092) + client = KafkaClient("localhost:9092") produce_example(client) consume_example(client) -- cgit v1.2.1