在Linux上安装Kafka的步骤如下:
sudo apt install openjdk-8-jdk
sudo yum install java-1.8.0-openjdk
java -version
命令确认JDK安装成功。tar -zxvf
命令解压下载的Kafka压缩包。例如:tar -zxvf kafka_2.13-3.2.0.tgz
mv kafka_2.13-3.2.0.tgz 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。nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup bin/kafka-server-start.sh config/server.properties &
ps -ef | grep zookeeper
命令查看Zookeeper进程。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在Linux上的基本安装流程,具体操作可能会因Linux发行版和Kafka版本的不同而略有差异。