Kafka的安装测试
在安装kafka之前,确保你的服务器上面JDK配置正确,最好用1.7的。下载地址: http://kafka.apache.org/downloads.html下载完成之后执行解压命令: tar -zxvf kafka_2.10-0.8.1.1.tgz启动服务首先启动zookeeper服务bin/zookeeper-server-start.sh c
·
在安装kafka之前,确保你的服务器上面JDK配置正确,最好用1.7的。
下载地址:
http://kafka.apache.org/downloads.html
下载完成之后执行解压命令: tar -zxvf kafka_2.10-0.8.1.1.tgz
启动服务
首先启动zookeeper服务
bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka
bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
查看服务是否启动:
创建topic:
创建topic
创建一个"test"的topic,一个分区一个副本
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看主题
查看主题
bin/kafka-topics.sh --list --zookeeper localhost:2181
查看主题详情
查看主题详情
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
创建生产者:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
创建消费者:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
更多推荐
已为社区贡献7条内容
所有评论(0)