Re: Setting writeTimestampToKafka from Kafka table descriptor

2019-12-29 Thread Jingsong Li
Hi Steve, There are some discussion in [1], this has been considered, but it is not supported in the current version. >From Fabian's word: > I think timestamp fields of source-sink tables should be handled as follows when emitting the table: - proc-time: ignore - from-field: simply write

Setting writeTimestampToKafka from Kafka table descriptor

2019-12-29 Thread Steve Whelan
Examining the *org.apache.flink.table.descriptors.Kafka* class in Flink v1.9, it seems to not have the ability to set whether the Kafka producer should attach a timestamp to the message. The *FlinkKafkaProducer* class has a setter for controlling this producer attribute. Can/should this attribute