canal.kafka

【文件属性】：
文件名称：canal.kafka
文件大小：46.11MB
文件格式：GZ
更新时间：2021-10-18 02:49:44
canal canal伪装成mysql的slave,发送dump命令从mysql增量订阅数据,并将数据实时发送到kafka,进行流式分析

【文件预览】：
bin
----startup.sh(3KB)
----startup.bat(1KB)
----stop.sh(1KB)
conf
----canal.properties(3KB)
----example()
--------instance.properties(1KB)
----metrics()
--------Canal_instances_tmpl.json(30KB)
----logback.xml(3KB)
----kafka.yml(403B)
----spring()
--------group-instance.xml(13KB)
--------tsdb()
--------default-instance.xml(9KB)
--------base-instance.xml(2KB)
--------file-instance.xml(8KB)
--------memory-instance.xml(8KB)
logs
lib
----spring-beans-3.2.9.RELEASE.jar(599KB)
----oro-2.0.8.jar(64KB)
----simpleclient-0.4.0.jar(58KB)
----zkclient-0.10.jar(73KB)
----canal.parse.dbsync-1.1.0.jar(93KB)
----canal.instance.manager-1.1.0.jar(29KB)
----simpleclient_common-0.4.0.jar(6KB)
----metrics-core-2.2.0.jar(80KB)
----spring-tx-3.2.9.RELEASE.jar(237KB)
----aopalliance-1.0.jar(4KB)
----netty-3.2.2.Final.jar(767KB)
----canal.store-1.1.0.jar(23KB)
----commons-math3-3.2.jar(1.61MB)
----aviator-2.2.1.jar(433KB)
----simpleclient_pushgateway-0.4.0.jar(6KB)
----jopt-simple-5.0.4.jar(76KB)
----guava-18.0.jar(2.15MB)
----fastsql-2.0.0_preview_540.jar(2.42MB)
----httpclient-4.5.1.jar(716KB)
----commons-beanutils-1.8.2.jar(226KB)
----spring-context-3.2.9.RELEASE.jar(846KB)
----httpcore-4.4.3.jar(319KB)
----scala-logging_2.11-3.8.0.jar(79KB)
----spring-jdbc-3.2.9.RELEASE.jar(396KB)
----kafka-clients-1.1.1.jar(1.64MB)
----kafka_2.11-1.1.1.jar(7.95MB)
----ibatis-sqlmap-2.3.4.726.jar(375KB)
----protobuf-java-2.6.1.jar(583KB)
----h2-1.4.196.jar(1.74MB)
----canal.server-1.1.0.jar(43KB)
----commons-lang-2.6.jar(278KB)
----canal.instance.core-1.1.0.jar(6KB)
----jcl-over-slf4j-1.7.12.jar(16KB)
----lz4-java-1.4.1.jar(361KB)
----spring-orm-3.2.9.RELEASE.jar(376KB)
----jmh-core-1.21.jar(501KB)
----canal.protocol-1.1.0.jar(261KB)
----canal.meta-1.1.0.jar(45KB)
----fastjson-1.2.28.jar(448KB)
----commons-logging-1.1.3.jar(61KB)
----logback-classic-1.1.3.jar(274KB)
----jackson-core-2.9.6.jar(316KB)
----simpleclient_hotspot-0.4.0.jar(17KB)
----jctools-core-2.1.2.jar(246KB)
----snakeyaml-1.17.jar(267KB)
----commons-codec-1.9.jar(258KB)
----canal.parse-1.1.0.jar(221KB)
----canal.common-1.1.0.jar(37KB)
----druid-1.1.9.jar(2.59MB)
----canal.deployer-1.1.0.jar(39KB)
----zookeeper-3.4.5.jar(762KB)
----jackson-databind-2.9.6.jar(1.29MB)
----canal.sink-1.1.0.jar(17KB)
----canal.prometheus-1.1.0.jar(42KB)
----snappy-java-1.1.7.1.jar(1.93MB)
----commons-compress-1.9.jar(369KB)
----spring-expression-3.2.9.RELEASE.jar(192KB)
----scala-library-2.11.12.jar(5.48MB)
----simpleclient_httpserver-0.4.0.jar(9KB)
----logback-core-1.1.3.jar(444KB)
----spring-core-3.2.9.RELEASE.jar(864KB)
----commons-io-2.4.jar(181KB)
----canal.parse.driver-1.1.0.jar(63KB)
----disruptor-3.4.2.jar(81KB)
----slf4j-api-1.7.12.jar(31KB)
----canal.instance.spring-1.1.0.jar(9KB)
----jackson-annotations-2.9.0.jar(65KB)
----netty-all-4.1.6.Final.jar(3.37MB)
----canal.filter-1.1.0.jar(12KB)
----spring-aop-3.2.9.RELEASE.jar(330KB)
----scala-reflect-2.11.12.jar(4.41MB)
----canal.kafka-1.1.0.jar(20KB)
----mysql-connector-java-5.1.40.jar(968KB)