| 适用 | 流处理读写环、跨主题原子写 |
|---|---|
| 关键配置 | transactional.id（唯一）、transaction.timeout.ms（默认 60000） |
| 读侧 | isolation.level=read_committed |
事务使用（Java 片段）
事务使用（Java 片段）
producer.initTransactions();
try {
producer.beginTransaction();
producer.send(record1);
producer.send(record2);
producer.sendOffsetsToTransaction(offsets, consumer.groupMetadata());
producer.commitTransaction();
} catch (Exception e) {
producer.abortTransaction();
}读端不设 read_committed 会读到未提交甚至中止的事务消息；下游跨系统写库时仍要保证幂等。