You have to implement a
SerializationSchema<myObject> and pass that into the
FlinkKinesisProducer.
The error message you received is
caused by the compiler attempting to determine the generic type of
the producer, but not being able to do so since your myObject
class does not implement the correct interface.
On 01/10/2019 20:59, Andres Angel
wrote:
Hello folks,
I need to create a flink producer for Kinesis capable to
sink a payload based on a custom class object I have build.
The official documentation comes with this basic example
assuming that we are sinking a string object:
FlinkKinesisProducer<String> kinesis = new FlinkKinesisProducer<>(new SimpleStringSchema(), producerConfig);
Based on that example I tried to implement my custom
producer in the way that I will return the need object.
FlinkKinesisProducer<myObject> kinesis = new FlinkKinesisProducer<>(new myObject(), producerConfig);
The problem with this approach is that I get an error right
on the FlinkKinesisProducer<> saying
that it's incapable to infer arguments
How would be the rightly way to sink this custom payload
object?
thanks so much
Locked
