最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

i am trying to use Flink FileSource and then KafkaSink - Stack Overflow

programmeradmin1浏览0评论

I am trying to use Flink FileSource and read a directory. in the directory can be multiple files and I want to sink them to Kafka. this is working fine. my problem is that I am trying to add the source file name into the Kafka headers, and cant get it to add. I am using Flink 1.20

I tried to override the reader but no file name,

发布评论

评论列表(0)

  1. 暂无评论