flink 消费 kafak
0 人感兴趣 · 3 次引用
- 最新
- 推荐

Apache flink - PartitionNotFoundException
2022-04-08 15:39:11.056 ERROR [Flink Netty Client (:) Thread 8] o.a.f.r.i.n.netty.CreditBasedPartitionRequestClientHandler - received error response from remote: [/11.50.9.166:14755], InputChannelID: [c0008c5d7cafb637a1fb8017ec610f04] erro

Pulsar Flink Connector 2.5.0 正式发布
经过不断地努力,社区成功发布 Pulsar Flink Connector 2.5.0 版本。Pulsar Flink Connector 集成了 Apache Pulsar 和 Apache Flink(数据处理引擎),允许 Apache Flink 向 Apache Pulsar 读写数据。
Flink 源码分析之 Flink startupMode 是如何起作用的
flink源码分析之Flink startupMode是如何起作用的