一、启动ZooKeeper

打开一个新终端并键入以下命令

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

二、要启动Kafka Broker，请键入以下命令

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

启动Kafka Broker后，在ZooKeeper终端上键入命令 jps ，您将看到以下响应

 821 QuorumPeerMain
 928 Kafka
 931 Jps

现在你可以看到两个守护进程运行在终端上，QuorumPeerMain是ZooKeeper守护进程，另一个是Kafka守护进程。

三、创建Kafka主题

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1    --partitions 1 --topic Hello-Kafka

四、主题列表
要获取Kafka服务器中的主题列表，可以使用以下命令

 bin/kafka-topics.sh --list --zookeeper localhost:2181

输出

 Hello-Kafka

五、启动生产者以发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka

六、启动消费者以接收消息

bin/kafka-console-consumer.sh --zookeeper localhost:2181 —topic Hello-Kafka --from-beginning

七、单节点多代理配置
创建多个Kafka Brokers，我们在配置/ server.properties中已有一个Kafka代理实例。 现在我们需要多个代理实例，因此将现有的server.prop-erties文件复制到两个新的配置文件中，并将其重命名为server-one.properties和server-two.properties。 然后编辑这两个新文件并分配以下更改

config / server-one.properties

# The id of the broker. This must be set to a unique integer for each broker.  
broker.id=1
# The port the socket server listens on
port=9093
# A comma seperated list of directories under which to store log files
log.dirs=/tmp/kafka-logs-1

创建主题
让我们为此主题将复制因子值指定为三个，因为我们有三个不同的代理运行。 如果您有两个代理，那么分配的副本值将是两个。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3  -partitions 1 --topic Multibrokerapplication

Describe 命令用于检查哪个代理正在侦听当前创建的主题

bin/kafka-topics.sh --describe --zookeeper localhost:2181  --topic Multibrokerappli-cation

输出

bin/kafka-topics.sh --describe --zookeeper localhost:2181 
--topic Multibrokerappli-cation

Topic:Multibrokerapplication    PartitionCount:1 
ReplicationFactor:3 Configs:

Topic:Multibrokerapplication Partition:0 Leader:0 
Replicas:0,2,1 Isr:0,2,1

八、修改主题

bin/kafka-topics.sh --zookeeper localhost:2181  --alter --topic Hello-kafka --parti-tions 2