我想从卡夫卡主题读取流数据,并写入S3的avro,或拼图,格式。数据流看起来像json字符串,但我不能转换和写入avro或拼图,格式的S3。我找到了一些代码片段并尝试但是我在addSink得到了“类型不匹配,预期的SinkFunctionString,实际的: StreamingFileSinkTextOut”
val .addSource=环境信宿(MyConsumerSource).
我是Apacheflink的新手,正在构建一个简单的应用程序,其中我从kinesis流中读取事件,例如 String id, Longamount对由id键控的上述流的字段amount执行聚合(sum)。该转换相当于SQL select sum(amount) from testevents group by id,其中testevents是到目前为止接收到的所有事件。聚合