flink 消费 kafka

0 人感兴趣 · 4 次引用

  • 推荐
  • 最新

深入了解 kafka 系列 - 消费者

用户头像
小技术君 2020 年 7 月 7 日

与生产者对应的是消费者,应用程序可以通过KafkaConsumer来订阅主题,并从订阅的主题中拉取消息。不过在使用KafkaConsumer消费消息之前需要先了解消费者和消费组的概念,否则无法理解如何使用KafkaConsumer。

Flink 获取 kafka 中每条消息对应的 topic

用户头像
shengjk1 2020 年 4 月 23 日

实战,Flink获取kafka中每条消息对应的topic

Flink 源码分析之 FlinkConsumer 是如何保证一个 partition 对应一个 thread 的

用户头像
shengjk1 2020 年 6 月 7 日

我们都知道flink 连接kafka时,默认是一个partition对应一个thread,它究竟是怎么实现的呢?以及到我们自己定义 RichParallelSourceFunction 的时候如何借鉴这部分代码呢?

flink 消费 kafka_flink 消费 kafka资料文章-InfoQ写作平台