elassandraFlow

ElassandraPOC 下载海滩传感器的示例数据（beach.csv），并将其放在相应的文件夹中。 安装 卡夫卡和动物园管理员服务 启动zookeeper和kafka服务器。 # starting zookeeper services bin/zkServer.sh start bin/zkCli.sh # starting kafka servers(brokers) bin/kafka-server-start.sh config/server.properties # create a topic named 'sensorsdata' bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic sensorsdata 将创建主题