bigdata finance

启动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