在 Linux 上启动 Kafka,通常按以下步骤进行(以 Kafka 自带 Zookeeper 的方式为例,适用于学习/测试环境):
java -version
tar -xzf kafka_2.13-3.x.x.tgz
cd kafka_2.13-3.x.x
Kafka 老版本依赖 Zookeeper:
# 后台启动
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
或前台启动(方便看日志):
bin/zookeeper-server-start.sh config/zookeeper.properties
# 后台启动
bin/kafka-server-start.sh -daemon config/server.properties
或前台启动:
bin/kafka-server-start.sh config/server.properties
jps
应看到:
QuorumPeerMain # Zookeeper
Kafka
或查看日志:
tail -f logs/server.log
# 创建 topic
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
# 生产消息
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
# 消费消息(另开终端)
bin/kafka-console-consumer.sh --topic test --bootstrap-server localhost:9092 --from-beginning
如果你使用的是 Kafka 3.x 且不想用 Zookeeper:
# 生成集群 ID
KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid)
# 格式化存储
bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties
# 启动
bin/kafka-server-start.sh -daemon config/kraft/server.properties
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh
如果你能告诉我:
我可以给你更精确的启动方式。