Apache Kafka交易数据流

问题描述 投票:0回答:1

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

apache-kafka message-queue distributed-transactions
1个回答
0
投票

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

© www.soinside.com 2019 - 2024. All rights reserved.