Apache Kafka 事务数据流
Apache Kafka transaction data flow
我正在阅读有关 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。
我正在阅读有关 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。