kafka保存偏移量到redis,启动时根据偏移量进行相关略修正

一、测试工具下载

1.1 下载zookeeper

https://zookeeper.apache.org/releases.html#download
测试我用的是 window版本zookeeper-3.6.3

1.3 启动服务

进入bin目录下,双击zkServer.cmd

2.1 安装kafka

kafka官 下载地址: http://kafka.apache.org/downloads.html

我下载的kafka_2.12-3.1.0.tgz,并解压到D:kafka目录下(解压的目录不能过深，启动脚本不支持很长的路径)

2.4写入数据

简单的往topic01里面写入10条数据

二 、代码

scala代码