We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bc9d04d commit 006e2b1Copy full SHA for 006e2b1
examples/mysql_to_kafka.py
@@ -59,8 +59,6 @@ def main():
59
60
producer.send(topic, key=None, value=message_body)
61
62
-
63
64
consumer = KafkaConsumer(
65
'deleted',
66
'updated',
0 commit comments