5.4. 可靠性保证

当写入单个分区后，idempotence 非常有用。与 idempotence 一起使用时，事务允许在多个分区间写入一次。

使用相同事务 ID 发送的事务消息只生成一次，因此只会所有都成功写入到相应的日志，或所有都没有写入。

...
...

# ...
enable.idempotence=true
max.in.flight.requests.per.connection=5
acks=all
retries=2147483647
transactional.id=UNIQUE-ID 

transaction.timeout.ms=900000 

# ...

选择 transactional.id 非常重要，以便保持事务保证。每个事务 ID 都应该用于一组唯一的主题分区。例如，这可以通过主题分区名称的外部映射到事务 ID 来实现，也可以使用避免冲突的功能从主题分区名称计算事务 ID。