如果你是用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 <[email protected]> 于2020年7月19日周日 下午9:36写道： > 大家好，我想通过avro格式sink到kafka,请问该怎么实现，官网上没找到相关方法。
