Canal kafka实例
资源文件列表
canal-demo/.idea/canal-demo.iml , 5210
canal-demo/.idea/compiler.xml , 645
canal-demo/.idea/encodings.xml , 138
canal-demo/.idea/inspectionProfiles/Project_Default.xml , 1444
canal-demo/.idea/libraries/Maven__aopalliance_aopalliance_1_0.xml , 514
canal-demo/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_1_3.xml , 568
canal-demo/.idea/libraries/Maven__ch_qos_logback_logback_core_1_1_3.xml , 547
canal-demo/.idea/libraries/Maven__com_101tec_zkclient_0_10.xml , 496
canal-demo/.idea/libraries/Maven__com_alibaba_fastjson_1_2_58.xml , 514
canal-demo/.idea/libraries/Maven__com_alibaba_otter_canal_client_1_1_4.xml , 559
canal-demo/.idea/libraries/Maven__com_github_luben_zstd_jni_1_3_7_1.xml , 541
canal-demo/.idea/libraries/Maven__com_google_guava_guava_18_0.xml , 499
canal-demo/.idea/libraries/Maven__com_google_protobuf_protobuf_java_3_6_1.xml , 574
canal-demo/.idea/libraries/Maven__commons_beanutils_commons_beanutils_1_8_2.xml , 594
canal-demo/.idea/libraries/Maven__commons_cli_commons_cli_1_2.xml , 514
canal-demo/.idea/libraries/Maven__commons_codec_commons_codec_1_9.xml , 536
canal-demo/.idea/libraries/Maven__commons_collections_commons_collections_3_2.xml , 602
canal-demo/.idea/libraries/Maven__commons_io_commons_io_2_4.xml , 503
canal-demo/.idea/libraries/Maven__commons_lang_commons_lang_2_6.xml , 525
canal-demo/.idea/libraries/Maven__commons_logging_commons_logging_1_1_1.xml , 572
canal-demo/.idea/libraries/Maven__io_netty_netty_all_4_1_6_Final.xml , 544
canal-demo/.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_1_1_33_Fork26.xml , 712
canal-demo/.idea/libraries/Maven__mysql_mysql_connector_java_5_1_48.xml , 574
canal-demo/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_7.xml , 556
canal-demo/.idea/libraries/Maven__org_apache_commons_commons_pool2_2_5_0.xml , 570
canal-demo/.idea/libraries/Maven__org_apache_kafka_kafka_clients_2_1_1.xml , 562
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_acl_4_5_2.xml , 567
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_client_4_5_2.xml , 588
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_common_4_5_2.xml , 588
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_logging_4_5_2.xml , 595
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_remoting_4_5_2.xml , 602
canal-demo/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_srvutil_4_5_2.xml , 595
canal-demo/.idea/libraries/Maven__org_apache_zookeeper_zookeeper_3_4_5.xml , 550
canal-demo/.idea/libraries/Maven__org_jboss_netty_netty_3_2_2_Final.xml , 544
canal-demo/.idea/libraries/Maven__org_lz4_lz4_java_1_5_0.xml , 491
canal-demo/.idea/libraries/Maven__org_slf4j_jcl_over_slf4j_1_7_12.xml , 548
canal-demo/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_12.xml , 513
canal-demo/.idea/libraries/Maven__org_springframework_spring_aop_3_2_18_RELEASE.xml , 616
canal-demo/.idea/libraries/Maven__org_springframework_spring_beans_3_2_18_RELEASE.xml , 630
canal-demo/.idea/libraries/Maven__org_springframework_spring_context_3_2_18_RELEASE.xml , 644
canal-demo/.idea/libraries/Maven__org_springframework_spring_core_3_2_18_RELEASE.xml , 623
canal-demo/.idea/libraries/Maven__org_springframework_spring_expression_3_2_18_RELEASE.xml , 665
canal-demo/.idea/libraries/Maven__org_springframework_spring_jdbc_3_2_18_RELEASE.xml , 623
canal-demo/.idea/libraries/Maven__org_springframework_spring_orm_3_2_18_RELEASE.xml , 616
canal-demo/.idea/libraries/Maven__org_springframework_spring_tx_3_2_18_RELEASE.xml , 609
canal-demo/.idea/libraries/Maven__org_xerial_snappy_snappy_java_1_1_7_2.xml , 566
canal-demo/.idea/libraries/Maven__org_yaml_snakeyaml_1_19.xml , 495
canal-demo/.idea/misc.xml , 472
canal-demo/.idea/modules.xml , 279
canal-demo/.idea/vcs.xml , 191
canal-demo/.idea/workspace.xml , 16683
canal-demo/canal-demo.iml , 81
canal-demo/canal.iml , 264
canal-demo/pom.xml , 2163
canal-demo/src/main/java/com/uptng/canal/AbstractCanalClientTest.java , 2759
canal-demo/src/main/java/com/uptng/canal/BaseCanalClientTest.java , 11929
canal-demo/src/main/java/com/uptng/canal/ClusterCanalClientTest.java , 1687
canal-demo/src/main/java/com/uptng/canal/SimpleCanalClientExample.java , 4137
canal-demo/src/main/java/com/uptng/canal/SimpleCanalClientPermanceTest.java , 2503
canal-demo/src/main/java/com/uptng/canal/SimpleCanalClientTest.java , 1485
canal-demo/src/main/java/com/uptng/canal/kafka/AbstractKafkaTest.java , 655
canal-demo/src/main/java/com/uptng/canal/kafka/CanalKafkaClientExample.java , 4779
canal-demo/src/main/java/com/uptng/canal/kafka/CanalKafkaClientFlatMessageExample.java , 4766
canal-demo/src/main/java/com/uptng/canal/kafka/CanalKafkaOffsetClientExample.java , 6475
canal-demo/src/main/java/com/uptng/canal/kafka/KafkaClientRunningTest.java , 1509
canal-demo/target/classes/com/uptng/canal/AbstractCanalClientTest.class , 3558
canal-demo/target/classes/com/uptng/canal/BaseCanalClientTest.class , 12555
canal-demo/target/classes/com/uptng/canal/ClusterCanalClientTest.class , 2381
canal-demo/target/classes/com/uptng/canal/SimpleCanalClientExample.class , 6025
canal-demo/target/classes/com/uptng/canal/SimpleCanalClientPermanceTest.class , 4199
canal-demo/target/classes/com/uptng/canal/SimpleCanalClientTest.class , 2494
canal-demo/target/classes/com/uptng/canal/kafka/AbstractKafkaTest.class , 905
canal-demo/target/classes/com/uptng/canal/kafka/CanalKafkaClientExample.class , 6010
canal-demo/target/classes/com/uptng/canal/kafka/CanalKafkaClientFlatMessageExample.class , 5853
canal-demo/target/classes/com/uptng/canal/kafka/CanalKafkaOffsetClientExample.class , 6342
canal-demo/target/classes/com/uptng/canal/kafka/KafkaClientRunningTest.class , 3065