Apache Kafka 事务数据流

Question

我正在阅读有关 Kafka 事务数据流的信息，我不清楚的一件事是协调器向每个分区的领导者发送 WriteTxnMarkerRequest 后会发生什么。我知道该请求使领导代理向日志写入控制消息，但他们是否以确认响应协调员？在他们的原始设计文档https://docs.google.com/document/d/11Jqy_GjUGtdXJK94XGsEIK7CP1SnQGdp2eF0wSw9ra8/edit#heading=h.bgy58z5pyzw7 中，数据流图看起来不像协调器等待确认。如果是这种情况，它是否只是将最终提交或中止消息写入事务日志？

Answer 1

事务中的分区领导者在将控制消息附加到日志后确实会响应协调器。这是根据合流页面https://cwiki.apache.org/confluence/display/KAFKA/Transactional+Messaging+in+Kafka。