根据flink1.8官网文档实现了自定义StreamTableSource,并且输入流使用了kafkaStream,更贴近实际应用。官网文档内容简单且有漏洞,直接按照官网文档编写会导致运行失败。附件文档中的代码经过验证可以正常运行,同时实现了RetractStreamSink,供大家参考。