Update mysql_to_logstash.py

toadzhou · web-flow · commit 18705e71ea16 · 2016-08-17T15:36:02.000+08:00
Repair the parameter error
diff --git a/examples/logstash/mysql_to_logstash.py b/examples/logstash/mysql_to_logstash.py
@@ -28,6 +28,7 @@
 def main():
     stream = BinLogStreamReader(
         connection_settings=MYSQL_SETTINGS,
+        server_id=3,
         only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent])
 
     for binlogevent in stream:
