Re: Can't send kafka message with timestamp

Hi, I think the problem is the SerializationSchema parameter. Best, QIngxiang Ma. 2018-04-26 20:59 GMT+08:00 Alexander Smirnov : > Hi, > > > I'm creating kafka producer with timestamps enabled following instructions at > https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connecto

Can't send kafka message with timestamp

Hi, I'm creating kafka producer with timestamps enabled following instructions at https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/kafka.html#kafka-producer Optional> customPartitioner = Optional.empty(); FlinkKafkaProducer011 result = new FlinkKafkaPr