近期要做一个云平台网联项目,初步定了框架,中间件涉及到kafka,先在自己电脑上测试的时候踩了坑记录下
kafka目前最新的版本2.12-3.0.0,但下载下来运行以后一直报错,然后回溯了几个版本,实测2.11可正常运行,下载地址附上:
https://archive.apache.org/dist/kafka/2.2.0/kafka_2.11-2.2.0.tgz
下载以后直接解压就能用,运行的一些数据和log日志默认放在当前磁盘的tmp文件下,如果有需求可以到config文件夹下修改zookeeper.properties,以及server.properties中的log.dirs
kafka自带zookeeper需要先启动,在kafka_2.11-2.2.0文件夹下打开命令窗口,因为启动需要指定配置文件,直接进bin更麻烦,先后输入以下指令启动zookeeper和kafka
//启动zookeeper
.binwindowszookeeper-server-start.bat configzookeeper.properties
//启动kafka
.binwindowskafka-server-start.bat configserver.properties
用下列命令创建一个test topic检测是否启动成功:
创建topic
.binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
//查询
.binwindowskafka-topics.bat --list --zookeeper localhost:2181
显示test则启动成功
//创建生产者
.binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test
//创建消费者
.binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
相关推荐: MQTT与物联网平台(一):基础知识和设备接入物联网平台的实现(以华为云为例)
文章目录 前言 一、MQTT是什么? 二、接入物联网平台(以华为云为例) 1.创建产品和新增设备 2.建立TCP连接 3.建立MQTT连接 三、学习交流群 前言 本文简单介绍了MQTT的基础知识和使用方法,以蓝牙WIFI双模芯片W801作为硬件设备,接入到华为…