flink sink到kafka

classic Classic list List threaded Threaded
3 messages Options
smq
Reply | Threaded
Open this post in threaded view
|

flink sink到kafka

smq
大家好,我想通过avro格式sink到kafka,请问该怎么实现,官网上没找到相关方法。
Reply | Threaded
Open this post in threaded view
|

Re: flink sink到kafka

godfrey he
如果你是用flink sql的,可以通过DDL的方式来定义kafka sink,参考 [1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html

Best,
Godfrey

smq <[hidden email]> 于2020年7月19日周日 下午9:36写道:

> 大家好,我想通过avro格式sink到kafka,请问该怎么实现,官网上没找到相关方法。
smq
Reply | Threaded
Open this post in threaded view
|

回复: flink sink到kafka

smq
谢谢,我试试

发送自 Windows 10 版邮件应用

发件人: godfrey he
发送时间: 2020年7月19日 23:06
收件人: user-zh
主题: Re: flink sink到kafka

如果你是用flink sql的,可以通过DDL的方式来定义kafka sink,参考 [1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html

Best,
Godfrey

smq <[hidden email]> 于2020年7月19日周日 下午9:36写道:

> 大家好,我想通过avro格式sink到kafka,请问该怎么实现,官网上没找到相关方法。