讀取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
相關文章
相關標籤/搜索