kafka避免消費丟失?