作者:史天舒

F Kafka Connector 是 F 内置的 Kafka 连接器,它包含了从 Kafka Topic 读入数据的 F Kafka Consumer 以及向 Kafka Topic 写出数据的 F Kafka Producer,除此之外 F Kafa Connector 基于 F Checkpoint 机制提供了完善的容错能力。本文从 F Kafka Connector 的基本使用到 Kafka 在 F 中端到端的容错原理展开讨论。

1.F Kafka 的使用

在 F 中使用 Kafka Connector 时需要依赖 Kafka 的版本,F 针对不同的 Kafka 版本提供了对应的 Connector 实现。

1.1 版本依赖

既然


收藏 打印