kafka+storm+influxdb的程序demo

2018-09-04 10:17:02.568 [Thread-1] INFO com.B_TopologyStart - 运行业务模式 2018-09-04 10:17:02.567 [Thread-2] INFO com.Z_TopologyStart - 运行zipkin模式 2018-09-04 10:17:16.525 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT 2018-09-04 10:17:16.526 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:host.name=DESKTOP-7MT1EV0 2018-09-04 10:17:16.527 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.version=1.7.0_80 2018-09-04 10:17:16.531 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.vendor=Oracle Corporation 2018-09-04 10:17:16.532 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.home=C:\Program Files\java\jdk1.7.0_80\jre 2018-09-04 10:17:16.532 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.class.path=E:\Java使用工程\workspace\kafka-storm\target\classes;C:\Users\DJ\.m2\repository\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;C:\Users\DJ\.m2\repository\ch\qos\logback\logback-classic\1.2.3\logback-classic-1.2.3.jar;C:\Users\DJ\.m2\repository\ch\qos\logback\logback-core\1.2.3\logback-core-1.2.3.jar;C:\Users\DJ\.m2\repository\org\apache\kafka\kafka_2.12\1.0.0\kafka_2.12-1.0.0.jar;C:\Users\DJ\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.9.1\jackson-databind-2.9.1.jar;C:\Users\DJ\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.9.0\jackson-annotations-2.9.0.jar;C:\Users\DJ\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.9.1\jackson-core-2.9.1.jar;C:\Users\DJ\.m2\repository\net\sf\jopt-simple\jopt-simple\5.0.4\jopt-simple-5.0.4.jar;C:\Users\DJ\.m2\repository\com\yammer\metrics\metrics-core\2.2.0\metrics-core-2.2.0.jar;C:\Users\DJ\.m2\repository\org\scala-lang\scala-library\2.12.3\scala-library-2.12.3.jar;C:\Users\DJ\.m2\repository\com\101tec\zkclient\0.10\zkclient-0.10.jar;C:\Users\DJ\.m2\repository\org\apache\kafka\kafka-clients\1.0.0\kafka-clients-1.0.0.jar;C:\Users\DJ\.m2\repository\org\lz4\lz4-java\1.4\lz4-java-1.4.jar;C:\Users\DJ\.m2\repository\org\xerial\snappy\snappy-java\1.1.4\snappy-java-1.1.4.jar;C:\Users\DJ\.m2\repository\org\apache\kafka\kafka-streams\1.0.0\kafka-streams-1.0.0.jar;C:\Users\DJ\.m2\repository\org\apache\kafka\connect-json\1.0.0\connect-json-1.0.0.jar;C:\Users\DJ\.m2\repository\org\apache\kafka\connect-api\1.0.0\connect-api-1.0.0.jar;C:\Users\DJ\.m2\repository\org\rocksdb\rocksdbjni\5.7.3\rocksdbjni-5.7.3.jar;C:\Users\DJ\.m2\repository\org\apache\storm\storm-core\1.2.1\storm-core-1.2.1.jar;C:\Users\DJ\.m2\repository\com\esotericsoftware\kryo\3.0.3\kryo-3.0.3.jar;C:\Users\DJ\.m2\repository\com\esotericsoftware\reflectasm\1.10.1\reflectasm-1.10.1.jar;C:\Users\DJ\.m2\repository\org\ow2\asm\asm\5.0.3\asm-5.0.3.jar;C:\Users\DJ\.m2\repository\com\esotericsoftware\minlog\1.3.0\minlog-1.3.0.jar;C:\Users\DJ\.m2\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;C:\Users\DJ\.m2\repository\org\clojure\clojure\1.7.0\clojure-1.7.0.jar;C:\Users\DJ\.m2\repository\com\lmax\disruptor\3.3.2\disruptor-3.3.2.jar;C:\Users\DJ\.m2\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;C:\Users\DJ\.m2\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;C:\Users\DJ\.m2\repository\org\slf4j\log4j-over-slf4j\1.6.6\log4j-over-slf4j-1.6.6.jar;C:\Users\DJ\.m2\repository\io\dropwizard\metrics\metrics-core\3.1.0\metrics-core-3.1.0.jar;C:\Users\DJ\.m2\repository\io\dropwizard\metrics\metrics-graphite\3.1.0\metrics-graphite-3.1.0.jar;C:\Users\DJ\.m2\repository\io\dropwizard\metrics\metrics-ganglia\3.1.0\metrics-ganglia-3.1.0.jar;C:\Users\DJ\.m2\repository\info\ganglia\gmetric4j\gmetric4j\1.0.7\gmetric4j-1.0.7.jar;C:\Users\DJ\.m2\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;C:\Users\DJ\.m2\repository\org\apache\storm\storm-kafka\1.2.1\storm-kafka-1.2.1.jar;C:\Users\DJ\.m2\repository\commons-io\commons-io\2.5\commons-io-2.5.jar;C:\Users\DJ\.m2\repository\org\apache\curator\curator-framework\4.0.0\curator-framework-4.0.0.jar;C:\Users\DJ\.m2\repository\org\apache\curator\curator-client\4.0.0\curator-client-4.0.0.jar;C:\Users\DJ\.m2\repository\org\apache\zookeeper\zookeeper\3.5.3-beta\zookeeper-3.5.3-beta.jar;C:\Users\DJ\.m2\repository\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;C:\Users\DJ\.m2\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar;C:\Users\DJ\.m2\repository\io\netty\netty\3.10.5.Final\netty-3.10.5.Final.jar;C:\Users\DJ\.m2\repository\commons-lang\commons-lang\2.5\commons-lang-2.5.jar;C:\Users\DJ\.m2\repository\com\googlecode\json-simple\json-simple\1.1\json-simple-1.1.jar;C:\Users\DJ\.m2\repository\com\alibaba\fastjson\1.2.41\fastjson-1.2.41.jar;C:\Users\DJ\.m2\repository\mysql\mysql-connector-java\5.1.28\mysql-connector-java-5.1.28.jar;C:\Users\DJ\.m2\repository\c3p0\c3p0\0.9.1.2\c3p0-0.9.1.2.jar;C:\Users\DJ\.m2\repository\org\influxdb\influxdb-java\2.5\influxdb-java-2.5.jar;C:\Users\DJ\.m2\repository\com\google\guava\guava\20.0\guava-20.0.jar;C:\Users\DJ\.m2\repository\com\squareup\retrofit2\retrofit\2.1.0\retrofit-2.1.0.jar;C:\Users\DJ\.m2\repository\com\squareup\retrofit2\converter-moshi\2.1.0\converter-moshi-2.1.0.jar;C:\Users\DJ\.m2\repository\com\squareup\moshi\moshi\1.2.0\moshi-1.2.0.jar;C:\Users\DJ\.m2\repository\com\squareup\okhttp3\okhttp\3.5.0\okhttp-3.5.0.jar;C:\Users\DJ\.m2\repository\com\squareup\okio\okio\1.11.0\okio-1.11.0.jar;C:\Users\DJ\.m2\repository\com\squareup\okhttp3\logging-interceptor\3.5.0\logging-interceptor-3.5.0.jar;C:\Users\DJ\.m2\repository\com\google\code\gson\gson\2.6.2\gson-2.6.2.jar;C:\Users\DJ\.m2\repository\redis\clients\jedis\2.7.3\jedis-2.7.3.jar;C:\Users\DJ\.m2\repository\org\apache\commons\commons-pool2\2.3\commons-pool2-2.3.jar 2018-09-04 10:17:16.533 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.library.path=C:\Program Files\java\jdk1.7.0_80\bin;C:\WINDOWS\Sun\Java\bin;C:\WINDOWS\system32;C:\WINDOWS;C:/Program Files/Java/jre1.8.0_102/bin/server;C:/Program Files/Java/jre1.8.0_102/bin;C:/Program Files/Java/jre1.8.0_102/lib/amd64;C:\ProgramData\Oracle\Java\javapath;C:\WINDOWS\system32;C:\WINDOWS;C:\WINDOWS\System32\Wbem;C:\WINDOWS\System32\WindowsPowerShell\v1.0\;C:\Program Files\TortoiseSVN\bin;C:\Program Files\java\jdk1.8.0_102\bin;C:\Program Files\java\jdk1.8.0_102\jre\bin;C:\Program Files\apache-maven-3.3.3\bin;C:\Program Files\apache-tomcat-7.0.69\bin;C:\Program Files\apache-tomcat-7.0.69\lib;C:\Program Files\apache-ant-1.9.6-bin\bin;C:\Program Files\apache-cxf-2.6.2\bin;C:\strawberry\c\bin;C:\strawberry\perl\bin;C:\Program Files (x86)\Skype\Phone\;C:\WINDOWS\System32\OpenSSH\;C:\Users\DJ\AppData\Local\Microsoft\WindowsApps;;E:\Java使用工程\eclipse;;. 2018-09-04 10:17:16.534 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.io.tmpdir=C:\TEMP\ 2018-09-04 10:17:16.534 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:java.compiler=<NA> 2018-09-04 10:17:16.534 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:os.name=Windows 8.1 2018-09-04 10:17:16.535 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:os.arch=amd64 2018-09-04 10:17:16.535 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:os.version=6.3 2018-09-04 10:17:16.535 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:user.name=DJ 2018-09-04 10:17:16.536 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:user.home=C:\Users\DJ 2018-09-04 10:17:16.536 [Thread-1] INFO o.a.s.s.o.apache.zookeeper.server.ZooKeeperServer - Server environment:user.dir=E:\Java使用工程\workspace\kafka-storm 2018-09-0