apache-kafka - Apache Kafka 事务数据流

Question

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

标签： apache-kafkamessage-queuedistributed-transactions

Answer 1

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