您的位置:

CentOS安装Kafka

一、CentOS7安装

在CentOS7上安装Kafka需要首先安装Java,命令如下:

sudo yum install java-1.8.0-openjdk

然后下载Kafka的二进制包,选择一个镜像站点进行下载,这里选择使用Apache的官方镜像站点:

wget https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz

解压Kafka:

tar -zxvf kafka_2.13-2.8.0.tgz

进入Kafka目录:

cd kafka_2.13-2.8.0

然后就可以运行Kafka了,这里启动Zookeeper服务:

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

在另一个终端窗口中启动Kafka服务:

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

二、CentOS安装应用

在使用Kafka之前,我们需要为它创建一个topic来存储消息:

bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092

这里我们创建一个名为“my-topic”的topic,使用默认的配置创建topic,Kafka的服务监听在本地主机的9092端口上。

然后我们可以启动一个消息生产者客户端,向topic中发送消息:

bin/kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:9092

在另一个终端窗口中启动一个消息消费者客户端,从topic中读取消息:

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

这里我们使用了“--from-beginning”参数,表示从topic的最早消息开始读取。

三、CentOS安装软件

如果你熟悉Docker的使用,可以使用Docker来安装Kafka,这样可以避免在本机上进行复杂的配置。首先拉取官方的Kafka镜像:

docker pull confluentinc/cp-kafka

然后运行Kafka容器:

docker run -p 9092:9092 \
      -e KAFKA_ADVERTISED_LISTENERS="PLAINTEXT://localhost:9092" \
      -e KAFKA_ZOOKEEPER_CONNECT="localhost:2181" \
      confluentinc/cp-kafka

通过以上命令可以创建一个可以访问的Kafka环境,

四、CentOS8安装yum

在CentOS8上安装Kafka需要启用额外的repository,使用以下命令安装Kafka:

sudo dnf install -y epel-release
sudo dnf install -y kafka

使用以下命令启动Kafka服务:

sudo systemctl start kafka

也可以使用以下命令设置Kafka服务为开机启动:

sudo systemctl enable kafka

五、CentOS7安装yum

在CentOS7上安装Kafka需要安装EPEL repository,并使用以下命令安装Kafka:

sudo yum install epel-release
sudo yum install kafka

使用以下命令启动Kafka服务:

sudo systemctl start kafka

也可以使用以下命令设置Kafka服务为开机启动:

sudo systemctl enable kafka

六、CentOS安装后配置

Kafka的配置文件位于“config/server.properties”,可以根据需要进行修改,如修改Kafka的监听端口:

listeners=PLAINTEXT://localhost:9092

要在Kafka的topic中设置副本数量,可以使用以下命令:

bin/kafka-topics.sh --alter --topic my-topic --partitions 3 --replication-factor 2 --zookeeper localhost:2181

这里将“my-topic”主题的分区数设置为3,副本数量设置为2。

七、安装CentOS7

在CentOS7上安装Kafka,需要先安装Java,然后按照第一部分的步骤进行安装配置。

八、安装CentOS dracut

在CentOS中使用dracut来生成initramfs镜像,可以在需要更改内核的情况下使用,使用以下命令安装dracut:

sudo yum install dracut

然后使用以下命令生成initramfs镜像:

sudo dracut -f /boot/initramfs-$(uname -r).img $(uname -r)

这里生成的initramfs镜像可以用于各种引导程序(如grub)来启动新内核。