# 测试zookeeper /usr/local/kafka/bin/kafka-topics.sh --zookeeper 100.98.233.12:2181 --list # 检测filebeat语法是否正确 /usr/share/filebeat/bin/filebeat -c /etc/filebeat/filebeat.yml # logstatsh检测语法 /usr/share/logstash/bin/logstash --path.settings /etc/logstash -f /etc/logstash/conf.d/ac.vipthink.cn.conf --config.test_and_exit # 通过 Zookeeper 去查看 /usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper 100.98.233.12:2181 --topic access_ac_vipthink --from-beginning # 通过 Kafka 本身去查看 /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server 100.98.233.12:2181 --topic efang --from-beginning