搜尋

首頁  >  問答  >  主體

java - sparkstreming不通过checkpoint怎么进行driver恢复,怎么解决???

sparkstreming读取kafka数据,不采用checkpoint来维护偏移量,自己通过zookeeper来维护,这里有一个问题如果sparkstreming的driver宕机,没有checkpoint怎么保证driver级别的恢复??

ringa_leeringa_lee2803 天前550

全部回覆(0)我來回復

無回覆
  • 取消回覆