kafka, storm集成DEMO

研究storm的起因是两个老大的一段对话,然后催生了现在要做的这个小项目,其中就要用到kafka和storm。于是,开始了storm和kafka的学习之路。

Zookeeper/kafka/storm安装

安装比较简单,分别从三个官网下载最新的release,解压,copy到/usr/local/下,习惯性的分别创建软连接。然后修改/etc/profile,把zookeeper/kafka/storm分别添加到环境变量中。
修改后的/etc/profile如下:

1
2
3
4
5
export ZOOKEEPER_HOME=/usr/local/zookeeper
export STORM_HOME=/usr/local/storm

export PATH=:$STORM_HOME/bin:$PATH
export PATH=$ZOOKEEPER_HOME/bin:$PATH

启动kafka

####启动Server

1
2
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

####创建主题

1
2
bin/kafka-create-topic.sh --zookeeper localhost:2181 --replica 1 --partition 1 --topic test
bin/kafka-list-topic.sh --zookeeperlocalhost:2181

创建producer

1
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

创建consumer

1
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

OK,到此,基本的环境搭建完成了。

linux绑定多网卡 JAVA中的ClassLoader

评论

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×