Path Lines of Code example/src/main/assembly/dev.xml 54 example/src/main/assembly/release.xml 54 example/src/main/conf/logback.xml 63 example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java 67 example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java 216 example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java 25 example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientPermanceTest.java 59 example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java 29 example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java 15 example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientExample.java 102 example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java 102 example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaOffsetClientExample.java 114 example/src/main/java/com/alibaba/otter/canal/example/kafka/KafkaClientRunningTest.java 34 example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java 12 example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java 111 example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientFlatMessageExample.java 92 example/src/main/resources/logback.xml 21