目录

1、下载和安装

1.1下载

1.2安装

2、启动kafka和zookeeper

2.1、启动kafka自带的zookeeper

2.2、启动kafka

2.3、关闭kafka

3、topic操作

3.1、创建topic

3.2、查看topic列表

3.3、查看分片信息

4、测试生产者和消费者

4.1、生产者

4.2、消费者

1、下载和安装

1.1下载

官网地址： https://kafka.apache.org/downloads

下载最新的稳定版本：

1.2安装

1、新建文件夹和日志文件夹：mkdir /opt/kafka， mkdir /opt/kafka/kafka-logs

2、下载kafka压缩包：wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz

3、解压压缩包：tar -zxvf  kafka_2.12-2.6.0.tgz

4、修改配置文件：（需要调整的配置文件）vim /opt/kafka/kafka_2.12-2.6.0/config/server.properties

#hostname
host.name=198.168.1.156

broker.id=0
#kafka对外提供服务的端口默认是9092
listeners=PLAINTEXT://198.168.2.255:9092
#日志路径
log.dirs=/opt/kafka/kafka-logs

#zookeeper地址
zookeeper.connect=198.168.2.255:2181
 

2、启动kafka和zookeeper

由于kafka和zookeeper集成使用，先启动kafka自带的zookeeper

2.1、启动kafka自带的zookeeper

/opt/kafka/kafka_2.12-2.6.0/bin/zookeeper-server-start.sh  /opt/kafka/kafka_2.12-2.6.0/config/zookeeper.properties

2.2、启动kafka

启动：                            /opt/kafka/kafka_2.12-2.6.0/bin/kafka-server-start.sh /opt/kafka/kafka_2.12-2.6.0/config/server.properties

守护进程方式启动kafka：/opt/kafka/kafka_2.12-2.6.0/bin/kafka-server-start.sh -daemon  /opt/kafka/kafka_2.12-2.6.0/config/server.properties

2.3、关闭kafka

/opt/kafka/kafka_2.12-2.6.0/bin/kafka-server-stop.sh

3、topic操作

3.1、创建topic

/opt/kafka/kafka_2.12-2.6.0/bin/kafka-topics.sh --create --zookeeper 198.168.2.255:2181 --replication-factor 1 --partitions 1 --topic demo

3.2、查看topic列表

/opt/kafka/kafka_2.12-2.6.0/bin/kafka-topics.sh --list --zookeeper 198.168.2.255:2181

3.3、查看分片信息

/opt/kafka/kafka_2.12-2.6.0/bin/kafka-topics.sh --describe --zookeeper 198.168.2.255:2181

4、测试生产者和消费者

4.1、生产者

/opt/kafka/kafka_2.12-2.6.0/bin/kafka-console-producer.sh --broker-list 198.168.2.255:9092 --topic demo

4.2、消费者

动态的消费消息
/opt/kafka/kafka_2.12-2.6.0/bin/kafka-console-consumer.sh --bootstrap-server 198.168.2.255:9092  --topic demo
消费所有的消息
/opt/kafka/kafka_2.12-2.6.0/bin/kafka-console-consumer.sh --bootstrap-server 198.168.2.255:9092  --topic demo --from-beginning

最后

以上就是英俊摩托为你收集整理的kafka集群和单机版安装教程  1、下载和安装2、启动kafka和zookeeper3、topic操作4、测试生产者和消费者的全部内容，希望文章能够帮你解决kafka集群和单机版安装教程  1、下载和安装2、启动kafka和zookeeper3、topic操作4、测试生产者和消费者所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。