在Debian系统上配置Kafka时,有几个关键点需要注意:
sudo apt install openjdk-8-jdk
sudo apt install zookeeperd
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -zxvf kafka_2.12-3.5.2.tgz
/etc/profile
文件中添加Kafka的安装目录和命令文件所在目录。export KAFKA_HOME=/path/to/kafka
export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile
server.properties
主要配置项:
broker.id
:每个Broker的唯一标识。listeners
:Kafka服务端使用的协议、主机名以及端口的格式。log.dirs
:用于存储日志文件的目录。num.partitions
:每个Topic默认的分区数量。log.retention.hours
和log.retention.bytes
:日志文件的保留时间和大小。num.recovery.threads.per.data.dir
:用于恢复日志文件的线程数量。log.flush.interval.messages
和log.flush.interval.ms
:触发日志刷新到磁盘的配置。acks=all
,retries=3
,Broker配置min.insync.replicas=2
。/etc/init.d/zookeeper start
bin/kafka-server-start.sh config/server.properties
server.properties
配置文件,并修改broker.id
和其他相关配置。bin/kafka-server-start.sh config/server-1.properties &
bin/kafka-server-start.sh config/server-2.properties &
通过以上步骤和注意事项,可以在Debian系统上成功配置Kafka,并避免一些常见的问题。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: 如何在Debian中监控Node.js应用