疑惑

来源:7-4 图解SparkStreaming整合Kafka offset的管理机制

慕九州3016327

2021-02-05

老师,启动kafka的时候必须要开启zookeeper,说明kafka里面数据元数据存放在zookeeper中,那么相应的各个消费者或者消费者组偏移量应该也默认保存到zookeeper中,那么再来一个MySQL保存,有啥意义吗老师

写回答

1回答

Michael_PK

2021-02-05

offset保存到MySQL中是一种维护方式。

sparkstreaming默认是提交在kafka的一个特殊topic中,但是这个操作是异步的

0
4
慕九州3016327
回复
Michael_PK
明白了感谢
2021-02-06
共4条回复

Spark3实时处理-Streaming+StructuredStreaming实战

实战Spark3实时处理,掌握两套企业级处理方案

340 学习 · 238 问题

查看课程

相似问题

疑惑

回答 1

疑惑

回答 1

疑惑

回答 1

spark疑惑

回答 1