在CentOS上高效部署Kafka需要遵循一系列步骤，以确保性能和稳定性。以下是一个详细的指南：

1. 环境准备

1.1 安装Java

Kafka需要Java运行环境，推荐使用OpenJDK或Oracle JDK。

sudo yum install java-1.8.0-openjdk-devel

验证安装：

java -version

1.2 下载并解压Kafka

从Apache Kafka官网下载最新版本的Kafka，并解压到指定目录。

wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -xzf kafka_2.13-3.2.0.tgz
mv kafka_2.13-3.2.0 /opt/kafka

2. 配置Kafka

2.1 配置server.properties

编辑/opt/kafka/config/server.properties文件，进行基本配置。

# Broker ID
broker.id=0

# Listen port
listeners=PLAINTEXT://:9092

# Log directory
log.dirs=/tmp/kafka-logs

# Zookeeper connection string
zookeeper.connect=localhost:2181

# Number of partitions for each topic
num.partitions=1

# Default replication factor
default.replication.factor=1

# Minimum in-sync replicas
min.insync.replicas=1

2.2 配置zookeeper.properties

编辑/opt/kafka/config/zookeeper.properties文件，进行基本配置。

dataDir=/tmp/zookeeper
clientPort=2181
maxClientCnxns=0

3. 启动Zookeeper和Kafka

3.1 启动Zookeeper

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

3.2 启动Kafka Broker

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

4. 创建Topic

创建一个Topic用于测试。

/opt/kafka/bin/kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

5. 生产者和消费者测试

5.1 启动生产者

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

输入消息并按回车键发送。

5.2 启动消费者

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

你应该能看到之前发送的消息。

6. 性能优化

6.1 调整JVM参数

编辑/opt/kafka/bin/kafka-server-start.sh文件，添加JVM参数。

export KAFKA_HEAP_OPTS="-Xmx4G -Xms4G"

6.2 调整Kafka配置

• 增加num.partitions以提高并行处理能力。
• 调整log.retention.hours以控制日志保留时间。
• 增加log.segment.bytes以减少日志段切换频率。

6.3 使用SSD

如果可能，使用SSD存储以提高I/O性能。

6.4 监控和日志

配置监控工具（如Prometheus和Grafana）来监控Kafka集群的性能，并定期检查日志文件以发现潜在问题。

7. 高可用性和扩展性

7.1 配置多个Broker

在多台机器上部署Kafka Broker，配置server.properties中的broker.id和listeners。

7.2 配置Zookeeper集群

在多台机器上部署Zookeeper，配置zookeeper.properties中的dataDir和clientPort。

7.3 配置Topic复制因子

增加Topic的复制因子以提高容错能力。

/opt/kafka/bin/kafka-topics.sh --alter --topic test-topic --replication-factor 3 --bootstrap-server localhost:9092

通过以上步骤，你可以在CentOS上高效地部署Kafka，并根据需要进行性能优化和高可用性配置。