读取kafka数据经过SparkStreaming处理，数据零丢失--使用jdbc存储offset

1.MySQL建立存储offset的表格java mysql> use hxh mysql> create table hxh_offset( topic varchar(32), groupid varchar(50), partitions int, fromoffset bigint, untiloffset

>>阅读原文<<