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 be added to the table descriptor? I assume it was
left out because the table descriptor wants to maintain backwards
compatibility with older versions of Kafka where this attribute is not
supported.

Reply via email to