Kafka单节点安装部署_单节点kafka

作者：weixin_40725706 | 2024-02-12 21:03:49

踩

单节点kafka

本文主要是基于Kafka最新版kafka_2.12-2.8.0进行配置，这里ZooKeeper服务器的搭建主要是用kafka内置的ZooKeeper便捷脚本来快速简单地创建一个单节点ZooKeeper实例。

1、本地下载kafka文件，然后再把文件放到linux中

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

小提示：

小伙伴们看到kafka_2.12-2.8.0.tgz压缩包会很疑惑到底kafka的版本号是什么？

以kafka_2.12-2.8.0.tgz为例，2.12表示scala的版本，因为Kafka服务器端代码完全由Scala语音编写，”-“ 后面的2.8.0表示的kafka的版本信息，kafka的命名都是遵循这个规则的。但是Kafka新版客户端代码完全由Java语言编写，当然，不是Scala不行了，那是因为之前的Scala程序员隐退了，所以在社区找来了一批Java程序员来写Kafka新版客户端。

2、解压kafka_2.12-2.8.0.tgz文件

tar -xzf kafka_2.12-2.8.0.tgz

cd kafka_2.12-2.8.0

Kafka解压后，具体目录结构如下图所示：

Kafka中重要的四大配置文件如下：

kafka最重要的配置文件server.properties内容详细说明：


# 每个broker在集群中唯一存在，数值必须是正数；kafka根据id来识别broker机器，当该服务的地址发生变化时，broker.id没有变化，则不会影响consumers的消息情况。
broker.id=0 
 
# broker server服务端口
port=9092
 
# broker的主机地址
host.name=localhost
 
# 套接字服务器侦听的地址
listeners=PLAINTEXT://192.168.243.133:9092
 
# 代理将向生产者和消费者公布主机名和端口。如果没有设置，
# 如果已配置，它将使用“侦听器”的值。否则，它将使用该值从java.net.InetAddress.getCanonicalHostName（）返回
advertised.listeners=PLAINTEXT://192.168.243.133:9092
 
# broker处理消息的最大线程数，一般情况下不需要去修改
num.network.threads=3
 
# broker处理磁盘IO的线程数，数值应该大于你的硬盘数
num.io.threads=8
 
# socket的发送缓冲区，socket的调优参数SO_SNDBUFF
socket.send.buffer.bytes=102400
 
# socket的接受缓冲区，socket的调优参数SO_RCVBUFF
socket.receive.buffer.bytes=102400
 
# socket请求的最大数值，防止serverOOM，message.max.bytes必然要小于socket.request.max.bytes，会被topic创建时的指定参数覆盖
socket.request.max.bytes=104857600
 
# kafka数据的存放地址，多个地址的话用逗号分割/root/kafka_2.12-2.8.0/log-1，/root/kafka_2.12-2.8.0/log-2
log.dirs=/root/kafka_2.12-2.8.0/logs
 
# 每个topic的分区个数，若是在topic创建时候没有指定的话会被topic创建时的指定参数覆盖
num.partitions=1
 
# 在启动时用于日志恢复和在关闭时刷新的每个数据目录的线程数。
num.recovery.threads.per.data.dir=1
 
# 组元数据内部主题“__consumer_offsets”和“__transaction_state”的复制因子
# 对于除开发测试之外的任何其他内容，建议使用大于1的值以确保可用性，例如3。
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
 
# 日志文件因使用年限而有资格删除的最短使用年限
log.retention.hours=168
 
# topic的分区是以一堆segment文件存储的，这个控制每个segment的大小，会被topic创建时的指定参数覆盖
log.segment.bytes=1073741824
 
# 文件大小检查的周期时间，是否处罚 log.cleanup.policy中设置的策略
log.retention.check.interval.ms=300000
 
# 必须配置项，zookeeper集群的地址，可以是多个，以逗号分隔开，一般端口都为2181。hostname1:port1,hostname2:port2,hostname3:port3
zookeeper.connect=192.168.243.133:2181
 
# ZooKeeper的连接超时时间
zookeeper.connection.timeout.ms=18000
 
# ZooKeeper的最大超时时间，就是心跳的间隔，若是没有反映，那么认为已经死了，不易过大
#zookeeper.session.timeout.ms=6000
 
#ZooKeeper集群中leader和follower之间的同步实际时间
#zookeeper.sync.time.ms =2000
 
#随着新成员加入组，重新平衡将进一步延迟的时长，默认最大延迟为3秒，这里将其覆盖为0，因为这有助于为开发和测试提供更好的开箱即用体验。
#但是，在生产环境中，默认值3秒更合适，因为这将有助于避免在应用程序启动期间进行不必要且可能代价高昂的重新平衡。
group.initial.rebalance.delay.ms=0

注意：测试kafka时（比如创建主题）用的IP地址和端口要跟listeners的一致。

3、启动ZooKeeper和Kafka服务器

（1）启动ZooKeeper服务器，要一直保存连接状态（这里用kafka包内的便携脚本快速创建一个单节点ZooKeeper实例）

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

测试Zookeeper服务是否开启，重新开一个连接。输入jps会发现多了一个进程

（2）启动kafka服务器，要一直保存连接状态（在新开的连接上启动）

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

测试Kafka服务是否启动，在重新开一个连接，输入jps查看当前运行进程

启动时容易出现的问题：

1）默认情况下，进程是在前台运行的，这时就把shell操作框给占据了，一旦Ctrl+c就会关闭掉服务，所以上面在启动服务器后为保存连接状态，就一直在新开连接。但是我们希望将其在后台启动，可以在启动ZooKeeper和kakfa服务器命令后面加一个‘ &’实现这个目的。

比如：bin/zookeeper-server-start.sh config/zookeeper.properties &

这时候Ctrl+c，也不用担心服务器的进程关闭了，可以接着进行操作！

2）启动zookeeper和kafka服务器一定要按顺序启动，否则kafka服务器会报错。

下面通过杀死已存在的zookeeper服务器进程，来查看kafka服务器的报错情况。其实再重启zookeeper服务器，kafka服务器就会自动连上了。

3）在我第二次启动Kafka服务时候报错The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.（翻译下：代理正在尝试加入错误的群集。配置的zookeeper.connect可能错误。）