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