在CentOS環境下配置Kafka時,有幾個關鍵點需要注意:
sudo yum install java-1.8.0-openjdk
java -version
tar -zxvf kafka_2.12-3.5.2.tgz
server.properties
文件:
broker.id
:確保每個Kafka broker的ID是唯一的。listeners
:指定Kafka監聽的IP地址和端口。log.dirs
:指定Kafka日志存儲的目錄。zookeeper.connect
:指定Zookeeper的地址和端口。
示例配置:broker.id=1
listeners=PLAINTEXT://your_server_ip:9092
log.dirs=/tmp/kafka-logs
zookeeper.connect=zookeeper_ip:2181
firewall-cmd --zone=public --add-port=2181/tcp --permanent
firewall-cmd --zone=public --add-port=9092/tcp --permanent
firewall-cmd --reload
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup bin/kafka-server-start.sh config/server.properties &
ps -ef | grep zookeeper
ps -ef | grep kafka
bin/kafka-topics.sh --create --topic test --bootstrap-server your_server_ip:9092 --replication-factor 1 --partitions 1
bin/kafka-console-producer.sh --topic test --bootstrap-server your_server_ip:9092
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server your_server_ip:9092
通過以上步驟和注意事項,可以在CentOS環境下成功配置Kafka,并確保其穩定性和性能。