一个消费者对应一个分区
kafka的幂等性 如果发送失败 sequence不会累加,就不会往分区里面存放信息 ,本来只是发送msg,现在额外发送 pid 和seq,可以避免消息重复,
生产者重复消息处理的适合