Hi, folks ! I’ve got a little question, I’m trying to save stream of events from Kafka into HDSF using org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink with AVRO serialization. If I properly understood, I should use some implementation of org.apache.flink.streaming.connectors.fs.Writer<T> for this purposes.
I found an existing implementation of avro writer org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter<K, V>, but my stream contains only value. What I need to do, if I want to write values from stream using a BucketingSing in avro format ? Thx.