本文主要向大家介绍了【云计算】kafka之单节点broker的部署和使用，通过具体的内容向大家展现，希望对大家学习云计算有所帮助。

一、前提准备

1.安装zookeeper

2.配置zookeeper

vi conf/zoo.cfg

修改存储目录

dataDir=/opt/modules/zookeeper

3.启动zk

bin/zkServer.sh start

二、kafka配置和启动

1.broker配置

properties文件：$KAFKA_HOME/config/server.properties

broker.id=0

# The port the socket server listens on

port=9092

# Hostname the broker will bind to. If not set, the server will bind to all interfaces

host.name=bigdata.ibeifeng.com

# A comma seperated list of directories under which to store log files

log.dirs=/opt/modules/kafka_2.11-0.10.2.1/data/0

# root directory for all kafka znodes.

zookeeper.connect=bigdata.ibeifeng.com:2181/kafka

2.启动kafka和创建topic

(1)启动kafka

bin/kafka-server-start.sh config/server.properties

(2)创建topic

kafka-topics.sh --create --zookeeper bigdata.ibeifeng.com:2181/kafka08 --replication-factor 1 --partitions 1 --topic hello_topic

(3)查看所有topic

kafka-topics.sh --describe --zookeeper bigdata.ibeifeng.com:2181/kafka08

三、测试

1.开启生产者

bin/kafka-console-producer.sh --broker-list bigdata.ibeifeng.com:9092 --topic hello_topic

2.开启消费者

bin/kafka-console-consumer.sh --zookeeper bigdata.ibeifeng.com:2181/kafka08 --topic hello_topic --from-beginning

本文由职坐标整理并发布，希望对同学们有所帮助。了解更多详情请关注职坐标大数据云计算大数据安全频道！