kafka技术记录
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 | /opt/kafka_2.10-0.9.0.1/bin/kafka-server-start.sh /opt/kafka_2.10-0.9.0.1/config/server.properties >/data2/kafka-logs/kafka.log & /opt/tomcat/jdk1.8.0_77/bin/java -cp KafkaOffsetMonitor-assembly-0.2.1.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.1.29:2181,192.168.1.30:2181,192.168.1.128:2181 --port 8181 --refresh 10.seconds --retain 1.days & bin/kafka-topics.sh --describe ad_nginx_log --zookeeper 192.168.1.29:2181,192.168.1.30:2181,192.168.1.128:2181 kafka.common.errors.NotLeaderForPartitionException: This server is bin/kafka-console-producer.sh --broker-list 192.168.1.29:9092,192.168.1.30:9092,192.168.1.128:9092 --topic ad_nginx_log bin/kafka-topics.sh --describe --zookeeper 192.168.1.29:2181,192.168.1.30:2181,192.168.1.128:2181 --topic ad_nginx_log bin/kafka-console-consumer.sh --zookeeper 192.168.1.29:2181,192.168.1.30:2181,192.168.1.128:2181 --topic ad_nginx_log --from-beginning /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties >/data2/kafka-logs/kafka.log & /opt/tomcat/jdk1.8.0_77/bin/java -cp KafkaOffsetMonitor-assembly-0.2.1.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 192.168.1.29:2181,192.168.1.30:2181,192.168.1.128:2181 --port 8181 --refresh 10.seconds --retain 1.days & bin/flume-ng agent -c conf/ -f conf/tail_kafka.conf -n a1 -Dflume.root.logger=INFO,console >/dev/null 2>&1 & /opt/apache-flume-1.6.0-bin/bin/flume-ng agent -c conf/ -f /opt/apache-flume-1.6.0-bin/conf/tail_kafka.conf -n a1 -Dflume.root.logger=INFO,console >/dev/null 2>&1 & /opt/apache-flume-1.6.0-bin/bin/flume-ng agent -c conf/ -f /opt/apache-flume-1.6.0-bin/conf/tail_kafka.conf -n a1 -Dflume.root.logger=INFO,console >/dev/null & |
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
