我正在阅读有关Kafka事务数据流的信息,但我不清楚的一件事是,协调器将WriteTxnMarkerRequest发送给每个分区的负责人。我知道请求使领导经纪人将控制消息写入日志,但是他们是否通过确认响应协调员?在他们的原始设计文档https://docs.google.com/document/d/11Jqy_GjUGtdXJK94XGsEIK7CP1SnQGdp2eF0wSw9ra8/edit#heading=h.bgy58z5pyzw7中,数据流程图似乎不像协调者在等待确认。如果是这样,是否只是将最终提交或中止消息写入事务日志?
事务中的分区负责人确实在将控制消息附加到日志后,确实会响应协调器。这是根据融合页面https://cwiki.apache.org/confluence/display/KAFKA/Transactional+Messaging+in+Kafka进行的。