启动Zookeeper $ ./bin/zookeeper-server-start.sh config/zookeeper.properties启动Kafka $ ./bin/kafka-server-start.sh config/server.properties创建Kafka主题$ ./bin/kafka-topics.sh --create --topic forex_events --zookeeper localhost:2181 --replication-factor 1 --partitions 1检查创建的主题列表$ ./bin/kafka-topics.sh --list --zookeeper localhost:2181手动读取发送到该主题的所有事件$ ./bin/kafka-console-consumer.sh --topic for