Flink的kafka的sink操作

Posted glblog

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink的kafka的sink操作相关的知识,希望对你有一定的参考价值。

1.环境准备:

  1.搭建zookeeper和kafka

  2.虚拟机上nc -l 9000方式产生数据

2.需求分析:

  通过socket的nc -l 9000方式产生数据,然后将数据以字符串的形式存入到kafka中

3.代码实例

  flink-kafka-example

以上是关于Flink的kafka的sink操作的主要内容,如果未能解决你的问题,请参考以下文章

flink sink

flink使用kafka作为source和sink

Flink的sink实战之四:自定义

Apache Flink:使用Apache Kafka作为Sink的简单demo(数据结果存放地方)

flink-kafka 简单例子(java) map, filter, sink

Flink的ES的sink操作