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
