在CentOS上配置Kafka网络时,有几个关键的技巧和步骤需要注意,以确保集群的高效性、安全性和稳定性。以下是详细信息:
sudo yum install java-1.8.0-openjdk-devel -y
wget https://archive.apache.org/dist/kafka/2.9.1/kafka_2.12-2.9.1.tgz
tar -zxvf kafka_2.12-2.9.1.tgz
sudo mv kafka_2.12-2.9.1 /opt/kafka
echo 'export PATH=$PATH:/opt/kafka/bin' >> ~/.bashrc
source ~/.bashrc
broker.id=1
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://<内网IP地址>:9092
log.dirs=/var/lib/kafka/logs
zookeeper.connect=localhost:2181
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=1048576
socket.receive.buffer.bytes=1048576
sudo firewall-cmd --zone=public --add-port=9092/tcp --permanent
sudo firewall-cmd --zone=public --add-port=2181/tcp --permanent
sudo firewall-cmd --reload
kafka-topics.sh
、kafka-console-producer.sh
、kafka-console-consumer.sh
等来监控集群的状态和性能指标。