Path	Lines of Code
client/src/main/java/com/alibaba/otter/canal/client/CanalConnector.java	19
client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java	37
client/src/main/java/com/alibaba/otter/canal/client/CanalMQConnector.java	14
client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java	51
client/src/main/java/com/alibaba/otter/canal/client/CanalNodeAccessStrategy.java	6
client/src/main/java/com/alibaba/otter/canal/client/ConsumerBatchMessage.java	32
client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java	300
client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterNodeAccessStrategy.java	86
client/src/main/java/com/alibaba/otter/canal/client/impl/ServerNotFoundException.java	20
client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java	476
client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleNodeAccessStrategy.java	27
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningData.java	24
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningListener.java	6
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java	189
client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java	251
client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaOffsetCanalConnector.java	67
client/src/main/java/com/alibaba/otter/canal/client/kafka/MessageDeserializer.java	17
client/src/main/java/com/alibaba/otter/canal/client/kafka/protocol/KafkaFlatMessage.java	18
client/src/main/java/com/alibaba/otter/canal/client/kafka/protocol/KafkaMessage.java	18
client/src/main/java/com/alibaba/otter/canal/client/pulsarmq/PulsarMQCanalConnector.java	291
client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/AliyunCredentialsProvider.java	27
client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java	250
client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java	284