117笔记问答在Linux上安装Kafka的步骤如下：
一、安装JDK
- 下载JDK：
- 对于Ubuntu/Debian系统：
sudo apt install openjdk-8-jdk - 对于CentOS/RedHat系统：
sudo yum install java-1.8.0-openjdk
- 验证安装：使用
java -version命令确认JDK安装成功。
二、下载和解压Kafka
- 下载Kafka：
- 访问Apache Kafka官方下载页面，下载适合的版本。
- 解压文件：
- 使用
tar -zxvf命令解压下载的Kafka压缩包。例如：tar -zxvf kafka_2.13-3.2.0.tgz
- 重命名解压后的目录（可选）：
mv kafka_2.13-3.2.0.tgz kafka
三、配置Kafka
-
进入配置目录：
cd /usr/local/kafka/config -
编辑
server.properties文件：
- 使用文本编辑器（如
vim）打开server.properties文件。 - 修改以下配置项：
broker.id：设置为唯一标识符，例如1。log.dirs：设置Kafka日志存储目录，例如/tmp/kafka-logs。zookeeper.connect：设置Zookeeper连接地址，例如zk_ip:2181。listeners：设置Kafka监听地址，例如PLAINTEXT://your_server_ip:9092。log.retention.hours：设置日志保留时间，例如168（表示一周）。delete.topic.enable：设置为true以允许删除topic。
四、启动Zookeeper和Kafka
- 启动Zookeeper：
- 在配置目录下运行：
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
- 启动Kafka：
- 在配置目录下运行：
nohup bin/kafka-server-start.sh config/server.properties &
五、测试Kafka
- 检查Zookeeper是否启动成功：
- 使用
ps -ef | grep zookeeper命令查看Zookeeper进程。
- 测试Kafka生产者和消费者：
- 生产者：进入Kafka目录，运行
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server your_server_ip:9092，然后输入消息测试。 - 消费者：运行
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server your_server_ip:9092，订阅并消费消息。
六、注意事项
- 确保Kafka和Zookeeper的配置文件中指定的端口（如9092和2181）未被其他服务占用。
- 根据实际需求调整Kafka的配置参数，如日志保留时间、监听地址等。
- 在生产环境中，建议使用最新稳定版本的Kafka，并仔细阅读版本更新日志以了解潜在的兼容性问题。
以上步骤为Kafka在Linux上的基本安装流程，具体操作可能会因Linux发行版和Kafka版本的不同而略有差异。