javaKafka面试题-如何保证数据不会丢失

生产者生产消息可以通过comfirm配置ack=all解决;

Broker同步过程中leader宕机可以通过配置ISR副本+重试解决;

消费者丢失可以关闭自动提交offset功能，系统处理完成时提交offset;