Flink-Kafka-Connector Flink结合Kafka实战
简介
Flink-kafka-connector用来做什么?
Kafka中的partition机制和Flink的并行度机制结合,实现数据恢复Kafka可以作为Flink的source和sink任务失败,通过设置kafka的offset来恢复应用
kafka简单介绍
关于kafka,我们会有专题文章介绍,这里简单介绍几个必须知道的概念。
讨喜的隔离可变性(十)使用Transactor
声明:本文是《Java虚拟机并发编程》的第五章,感谢华章出版社授权并发编程网站发布此文,禁止以任何形式转载此文。
Akka transactor或事务角色为我们提供了一种将多个角色的执行过程合并到一个事务中的方法。