kafka单机版部署


下载kafka

在官网下载kafka最新版本。

如:当前最新2.4.0,针对Scala不同版本有不同的编译包,下载Scala 2.12的测试。

wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz
# 解压
tar -xzf kafka_2.12-2.4.0.tgz

#进入目录
cd kafka_2.12-2.4.0

启动

启动zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka

bin/kafka-server-start.sh config/server.properties

如果需要放到后台运行,可以加上&或者 nohup命令.
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &

测试

创建主题

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

查看主题列表

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

向主题发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

从主题消费消息

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

搭建kafka集群

参考官网


文章作者: wuzhiyong
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 wuzhiyong !
评论
 上一篇
flink视频教程学习笔记 flink视频教程学习笔记
视频地址视频地址 基础定义有界/无界数据流有状态计算 例如:过去一段时间的点击量状态可持久化 时间官网 事件发生时间 事件进入flink时间 flink处理事件时间 API3层API 应用场景 Data Pipeline Data An
2020-03-10
下一篇 
zookeeper单机版部署 zookeeper单机版部署
下载压缩包wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.5.7/apache-zookeeper-3.5.7-bin.tar.gz tar -zxvf apache-
2020-03-03
  目录