在CentOS 6.5上安装Kafka需要遵循一定的步骤，并确保系统满足Kafka的运行要求。以下是一个详细的安装指南：
一、安装前准备
-
系统要求：
- CentOS 6.5操作系统
- JDK 1.8或更高版本（Kafka依赖于Java环境）
- Zookeeper（Kafka依赖于Zookeeper进行元数据管理）
-
下载相关软件：
- 从Apache Kafka官网下载Kafka安装包，例如
kafka_2.13-3.4.0.tgz。 - 下载并安装JDK，例如JDK 1.8。
- 下载并安装Zookeeper，或者使用Kafka自带的Zookeeper（但需要注意版本兼容性）。
- 从Apache Kafka官网下载Kafka安装包，例如
二、安装JDK
-
上传并解压JDK安装包：
# 使用scp或其他文件传输工具将JDK安装包上传到服务器 # 解压JDK安装包 tar -zxvf jdk-8uXXX-linux-x64.tar.gz -
配置环境变量：
# 编辑~/.bash_profile文件 vi ~/.bash_profile# 添加以下内容到文件中 export JAVA_HOME=/path/to/jdk1.8.0_XXX export PATH=$JAVA_HOME/bin:$PATH# 保存并退出 :wq# 使新配置的环境变量生效 source ~/.bash_profile -
验证JDK安装：
java -version
三、安装Zookeeper
-
上传并解压Zookeeper安装包：
# 使用scp或其他文件传输工具将Zookeeper安装包上传到服务器 # 解压Zookeeper安装包 tar -zxvf zookeeper-3.4.XX.tar.gz -
配置Zookeeper：
- 编辑
conf/zoo.cfg文件，配置Zookeeper的相关参数，如dataDir、clientPort等。 - 在同一目录下创建
myid文件，并写入一个唯一的数字作为Zookeeper节点的ID。
- 编辑
-
启动Zookeeper：
# 进入Zookeeper的bin目录 cd zookeeper-3.4.XX/bin# 启动Zookeeper服务 ./zkServer.sh start
四、安装Kafka
-
上传并解压Kafka安装包：
# 使用scp或其他文件传输工具将Kafka安装包上传到服务器 # 解压Kafka安装包 tar -zxvf kafka_2.13-3.4.0.tgz -
配置Kafka：
- 编辑
config/server.properties文件，配置Kafka的相关参数，如broker.id、listeners、zookeeper.connect等。broker.id：每个Kafka节点的唯一标识符，集群中每个节点的broker.id必须不同。listeners：Kafka监听的地址和端口，通常设置为服务器的内网IP和Kafka的默认端口（9092）。zookeeper.connect：Zookeeper集群的地址和端口，用于Kafka与Zookeeper的通信。
- 如果需要配置内外网不同的访问，可以添加
advertised.listeners参数，并设置相应的地址和端口。
- 编辑
-
启动Kafka：
# 进入Kafka的bin目录 cd kafka_2.13-3.4.0/bin# 启动Kafka服务 ./kafka-server-start.sh config/server.properties
五、验证安装
-
创建Topic：
# 创建一个名为test的Topic ./kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 -
发送消息：
# 向test Topic发送一条消息 ./kafka-console-producer.sh --topic test --bootstrap-server localhost:9092 # 在提示符下输入消息内容后按回车发送 -
接收消息：
# 从test Topic接收消息 ./kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092 --from-beginning # 此时应该会看到之前发送的消息内容
通过以上步骤，您应该能够在CentOS 6.5上成功安装并运行Kafka。请注意，Kafka和Zookeeper的版本需要兼容，且在实际生产环境中，建议对Kafka和Zookeeper进行集群部署以提高可用性和容错性。
