flink sink到kafka，报错Failed to construct kafka producer

2021-01-21 文章 lp
flink1.11.2 自定义source循环产生数据然后sink到kafka 采用application Mode部署作业到yarn， jobmanager.log报错如下：（jobmanager和taskmanager的container都分配了，报错都是如下） 2021-01-21 10:52:17,742 INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - Calculating tasks to restart to

回复: flink sink到kafka

2020-07-19 文章 明启 孙
谢谢，我试试 发送自 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 <374060...@qq.com>

Re: flink sink到kafka

2020-07-19 文章 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 <374060...@qq.com> 于2020年7月19日周日 下午9:36写道： > 大家好，我想通过avro格式sink到kafka,请问该怎么实现，官网上没找到相关方法。

flink sink到kafka

2020-07-19 文章 smq
大家好，我想通过avro格式sink到kafka,请问该怎么实现，官网上没找到相关方法。