关于sink失败 不消费kafka消息的处理

[范超]

大家好，我现在有个疑问
目前我使用kafka作为source，经过计算以后，将结果sink到数据库；
后来日志数据库发生了timeout或者宕机，kafka这边的主题，却消费掉了造成了数据丢失，那么如何设置才可以确认在sink失败的时候，不提交kafka的消费位移呢？


多谢大家了

范超