Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka

我测试操纵的进程如下：

• 启动flink-topic和flink-topic-output的斲丧拉取;
• 通过呼吁向flink-topic中添加测试动静only for test;
• 通过呼吁打印验证添加的测试动静 only for test;
• 最简朴的FlinkJob source->map->sink 对测试动静举办map处理赏罚："Flink study ".concat(s);
• 通过呼吁打印sink的数据;

(2) 内置Schemas

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!