kafka单机测试环境搭建

你的名字 2022-06-03 00:13 228阅读 0赞

##### 参考官网：[http://kafka.apache.org/quickstart][http_kafka.apache.org_quickstart] #####

**kafka在使用之前必须先启动zookeeper，但kafka的安装包中都带有zookeeper，所以小编没有单独下载、安装zookeeper。**

kafka\_2.11-1.0.0安装包下载地址：[https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka\_2.11-1.0.0.tgz][https_www.apache.org_dyn_closer.cgi_path_kafka_1.0.0_kafka_2.11-1.0.0.tgz]

### 1.解压kafka安装包。 ###

![这里写图片描述][SouthEast]

### 2.启动zookeeper ###

#### 内置的zookeeper的配置文件在kafka\_2.11-1.0.0/config目录下，一般不需要配置。 ####

![这里写图片描述][SouthEast 1]

#### zookeeper的启动命令在kafka\_2.11-1.0.0/bin目录下。 ####

![这里写图片描述][SouthEast 2]

#### 在kafka\_2.11-1.0.0目录下输入启动命令 ####

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

#### 出现下面界面代表启动成功，注意不是卡住了，我就是以为卡住了，找了一下午的问题。。。。。 ####

![这里写图片描述][SouthEast 3]

### 3.启动kafka ###

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

#### 出现下面界面代表启动成功 ####

![这里写图片描述][SouthEast 4]

### 4.创建topic ###

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

### 5.发送测试信息(生产者) ###

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    
    //弹出“>”符号后输入下面两行测试信息
    
    This is a message
    This is another message

### 6.接收信息（消费者） ###

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

### 7.接收到下列信息代表成功 ###

This is a message
    This is another message

[http_kafka.apache.org_quickstart]: http://kafka.apache.org/quickstart
[https_www.apache.org_dyn_closer.cgi_path_kafka_1.0.0_kafka_2.11-1.0.0.tgz]: https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.11-1.0.0.tgz
[SouthEast]: /images/20220603/5e0fbf9d46104881be44972c9185bcf9.png
[SouthEast 1]: /images/20220603/f5c36cdad72d46c7b6d91d0efdb2e4c4.png
[SouthEast 2]: /images/20220603/b31fba265e394dbea3914075541843de.png
[SouthEast 3]: /images/20220603/3f0a8cc4508544859a1b6d8b473f5bca.png
[SouthEast 4]: /images/20220603/ba6b5087e77442208b4a1dd64610e513.png