例如从kafka消费数据，使用sparkstream计算Wordcount，要求保证准确性，实时性，可用性，你要怎么实现？

如果计算时突然宕机，怎么保证消费kafka数据不丢失，不重复？ 

使用Kafka对接SparkStreaming计算，那么要保证数据不丢失，和不重复的话，要使用直连方式，并且保证一次性语义，手动管理Offset即可，那么在实现过程中，Offset一定不能丢，所以要手动管理，然后把它保存到其他存储位置即可，每次能拿到保存好的Offset就OK，同时如果Kafka突然宕机或者SparkStreaming宕机都不用担心，只要设置好一次性语义保存幂等数据不会丢，而且Offset在这次任务失败时候不会被提交，所以也不会更新，下次再次消费即可。