summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
Diffstat (limited to 'example.py')
-rw-r--r--example.py2
1 files changed, 1 insertions, 1 deletions
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)