Skip to content

Commit 888f206

Browse files
author
Mark Roberts
committed
Update load_example
1 parent 112158f commit 888f206

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

load_example.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class Producer(threading.Thread):
1212
big_msg = "1" * msg_size
1313

1414
def run(self):
15-
client = KafkaClient("localhost", 9092)
15+
client = KafkaClient("localhost:9092")
1616
producer = SimpleProducer(client)
1717
self.sent = 0
1818

@@ -25,7 +25,7 @@ class Consumer(threading.Thread):
2525
daemon = True
2626

2727
def run(self):
28-
client = KafkaClient("localhost", 9092)
28+
client = KafkaClient("localhost:9092")
2929
consumer = SimpleConsumer(client, "test-group", "my-topic",
3030
max_buffer_size = None,
3131
)

0 commit comments

Comments
 (0)