Re: Json KAFKA producer

Hi, SerializationSchema is a public interface that you can implement. It has a single method to turn an object into a byte array. I would suggest to implement your own SerializationSchema. Best, Fabian 2018-04-11 15:56 GMT+02:00 Luigi Sgaglione : > Hi, > > I'm

Json KAFKA producer

Hi, I'm trying to create a Flink example with kafka consumer and producer using Json data format. In particular, I'm able to consume and process Json data published on a Kafka topic, but not to publish the results. The problem is that I don't know what is the serialization schema that should be