向各位老師請教個問題：目前我們公司用的華為的大數(shù)據(jù)集群，有一個spark stream程序使用Direct模式實時消費kafka數(shù)據(jù)，程序是java開發(fā)的，由zookeeper管理offset，程序經(jīng)常有有掛掉的情況，通常是手動重啟，本人猜測是程序掛掉導(dǎo)致的數(shù)據(jù)丟失，但是這個地方想不通，請各位幫幫忙