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