a. Producer到broker
把request.required.acks设为1，丢会重发，丢的概率很小
b. Broker
b.1 对于broker，落盘的数据，除非磁盘坏了，不会丢的
b.2 对于内存中没有flush的数据，broker重启会丢
可以通过log.flush.interval.messages和log.flush.interval.ms来配置flush间隔，interval大丢的数据多些，小会影响性能
但在0.8版本，可以通过replica机制保证数据不丢，代价就是需要更多资源，尤其是磁盘资源，kafka当前支持GZip和Snappy压缩，来缓解这个问题
是否使用replica取决于在可靠性和资源代价之间的balance