main方法读取config、version参数，然后通过config.NewKingbusServerConfig(*configFile)获取serverCfg，之后通过server.NewKingbusServer(serverCfg)创建KingbusServer，然后执行ks.Run()

otter/node/common/src/main/java/com/alibaba/otter/node/common/config/model/NodeTask.java

otter/node/etl/src/main/java/com/alibaba/otter/node/etl/OtterController.java

otter/node/deployer/src/main/java/com/alibaba/otter/node/deployer/OtterLauncher.java

puma/puma/src/main/java/com/dianping/puma/biz/service/ClientPositionService.java

序 本文主要研究一下puma的Sender Sender puma/puma/src/main/java/com/dianping/puma/sender/Sender.java {代码...} Sender定义了getName、send方法 AbstractSender puma/puma/src/main/java/com/dianping/puma/sender/AbstractSender.java {代码...} AbstractSender声明实现了Sender接口，其send方法通过while循环执行...

puma/puma/src/main/java/com/dianping/puma/sender/dispatcher/Dispatcher.java

puma/core/src/main/java/com/dianping/puma/core/event/ChangedEvent.java

puma/puma/src/main/java/com/dianping/puma/datahandler/DataHandler.java

puma/puma/src/main/java/com/dianping/puma/taskexecutor/TaskExecutor.java

puma/puma/src/main/java/com/dianping/puma/parser/DefaultBinlogParser.java

SpinalTap/spinaltap-model/src/main/java/com/airbnb/spinaltap/mysql/Transaction.java

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/filter/MysqlEventFilter.java

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/event/BinlogEvent.java

SpinalTap/spinaltap-mysql/src/main/java/com/airbnb/spinaltap/mysql/binlog_connector/BinaryLogConnectorSource.java

nifi-1.11.4/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/io/AbstractBinlogTableEventWriter.java

nifi-1.11.4/nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/event/BinlogEventListener.java

rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/ColumnParser.java

rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Replicator.java

rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventProcessor.java

rocketmq-externals/rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPositionManager.java

debezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/util/ElapsedTimeStrategy.java

debezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/spi/OffsetCommitPolicy.java

debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/RecordMakers.java

debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java

debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.java

debezium-v1.1.1.Final/debezium-embedded/src/main/java/io/debezium/connector/simple/SimpleSourceConnector.java

debezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/DebeziumEngine.java

debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.java

debezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/heartbeat/Heartbeat.java