Kafka保证数据消费且只消费一次

1. 幂等性（Producer）：保证发送单个分区的消息只会发送一次，不会出现重复消息
2. 事务（Transaction）：保证原子性的写入多个分区，即写入到多个分区的消息要么全部成功，要么全部回滚处理EOS：流处理本质上可看成是“读取-处理-写入”的管道。此EOS保证整个过程的操作是原子性。注意，这只适用于Kafka Streams