我正在读关于Kafka事务数据流的文章,有一件事我不清楚,那就是协调器将WriteTxnMarkerRequest发送给每个分区的领导者之后会发生什么。我理解该请求使领导者代理将控制消息写入日志,但是它们是否用确认来响应协调器?在最初的设计文档https://docs.google.com/document/d/11Jqy_GjUGtdXJK94XGsEIK7CP1SnQGdp2eF0wSw9ra8/edit#heading=h.bgy58z5pyzw7中,数据流程图看起来并不像协调器在等待确认。如果是这样,它是否只是将最终提交或中止消息写入事务日志?
发布于 2019-10-28 17:19:36
一旦协调器将控制消息附加到日志,事务中的分区领导者确实会响应协调器。这是根据汇合页面的https://cwiki.apache.org/confluence/display/KAFKA/Transactional+Messaging+in+Kafka。
https://stackoverflow.com/questions/58542725
复制相似问题