kafka安装配置及测试-单机版(转)
kafka安装配置比较简单,只需要从官网下载相关jar包,然后解压就可以了。
下面是我用到的各个软件的版本:
linux系统:centos 7 64位
JDK版本:jdk1.8.0_91
zookeeper: zookeeper-3.4.10
kafka版本:kafka_2.11-1.0.0
2. 安装:
a. JDK安装不在详细描述,可以看之前的博客;b. 安装zookeeper,参考http://blog.****.net/yongge1981/article/details/78894715;
c. 安装kafka,解压
tar -xzvf kafka_2.11-1.0.0 mv kafka_2.11-1.0.0 kafka211
/bin 启动和停止命令等。
/config 配置文件
/libs 类库3. 启动和停止
首先启动zookeeper server, cd到zookeeper目录下,
./bin/zkServer.sh start
启动kafka server, cd到kafka目录下;
./bin/kafka-server-start.sh config/server.properties
4. 单机连通性测试
运行producer:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
运行consumer:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
在producer端输入字符串并回车,查看consumer端是否显示。
转发:http://czj4451.iteye.com/blog/2041096