flink将数据写入到kafka

编程入门行业动态更新时间:2024-10-27 10:22:39

flink将<a href=https://www.elefans.com/category/jswz/34/1771445.html style= 数据写入到kafka"/>

在之前的一篇中，我们谈到在flink中如何读取来自kafka指定topic的数据，在实际生产环境中，比较常见的场景是，kafka作为数据源，flink程序读取到kafka的数据后，进行初步的处理后，再将数据会写到kafka的另一个topic中，供后面的应用读取使用

本例模拟从外部文件中读取数据，然后写入到kafka的指定topic中

环境准备

启动kafka服务，并通过控制台启动kafka指定topic的消费端窗口，这里我们还是使用之前那个 "zcy"的topic，使用下面的命令启动消费端窗口

./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic zcy

我们仍然读取下面的文件数据

更多推荐

flink将数据写入到kafka

本文发布于:2024-03-08 19:36:28，感谢您对本站的认可！

数据 flink kafka

评论列表（有 0 条评论）