在CentOS上搭建Kafka的步骤如下:
首先,确保你的系统已经安装了Java。如果没有安装,可以使用yum命令直接安装JDK 1.8:
yum -y install java-1.8.0*
访问Kafka官网https://www.apache.org/dyn/closer.cgi?path=/kafka/2.8.0/kafka_2.12-2.8.0.tgz,下载Kafka安装包。
将下载的Kafka安装包解压到你指定的目录,例如:
tar -zxvf kafka_2.12-2.8.0.tgz -C /opt/kafka/
进入Kafka的配置目录,编辑server.properties
文件,配置Kafka的相关参数。例如:
vi /opt/kafka/kafka_2.12-2.8.0/config/server.properties
修改以下内容:
broker.id
:为Kafka broker分配一个唯一的标识。broker.list
:列出所有Kafka broker的地址。host.name
:设置Kafka broker的主机名。port
:设置Kafka broker的监听端口。log.dirs
:设置Kafka数据和日志的存储目录。zookeeper.connect
:设置连接到Zookeeper集群的地址。在Kafka目录下,启动Zookeeper和Kafka服务:
/opt/kafka/kafka_2.12-2.8.0/bin/zookeeper-server-start.sh /opt/kafka/kafka_2.12-2.8.0/config/zookeeper.properties
/opt/kafka/kafka_2.12-2.8.0/bin/kafka-server-start.sh /opt/kafka/kafka_2.12-2.8.0/config/server.properties
使用以下命令创建一个名为test
的topic,并验证消息的生产和消费:
/opt/kafka/kafka_2.12-2.8.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
/opt/kafka/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
echo "hello world" | /opt/kafka/kafka_2.12-2.8.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
/opt/kafka/kafka_2.12-2.8.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
如果一切正常,你应该能够在控制台看到发送和消费的消息。
以上步骤是在CentOS 7.9上搭建单节点的Kafka环境,如果你需要搭建Kafka集群,可以参考相关教程或文档进行操作。