1.首先从官网下载后的tgz包上传到服务器上面

cp   kafka_2.12-2.1.1.tgz  /opt/

然后解压 tar -zxvf  kafka_2.12-2.1.1.tgz

2.环境变量配置(可以选做)

vim /etc/profile

3.设置单机启动

修改配置文件

cd /opt/kafka_2.12-2.1.1/config/

vim server.properties

修改日志路径

log.dirs=/opt/kafka_2.12-2.1.1

zookeeper.connect=zookeeper:2181 (这了zookeeper是已经映射了ip地址)

4启动

nohup /opt/kafka_2.12-2.1.1/bin/kafka-server-start.sh /opt/kafka_2.12-2.1.1/config/server.properties&

或者./bin/kafka-server-start.sh -daemon config/server.properties

查看日志是否有问题

tail -n50 -f /opt/kafka_2.12-2.1.1/nohup.out

没有错误启动成功了

5.来个很简单的测试

/opt/kafka_2.12-2.1.1/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

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

以上就是kafka安装和启动

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐