Hi, I am using Flink 1.3.2. When I try to use KafkaProducer with timestamps it fails to set name, uid or parallelism. It uses default values.
——— FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T> producer = FlinkKafkaProducer010 .writeToKafkaWithTimestamps(stream, topicName, schema, props, partitioner); producer.setFlushOnCheckpoint(flushOnCheckpoint); producer.name("foo") .uid("bar") .setParallelism(5); return producer; ——— As operator name it shows "FlinKafkaProducer 0.10.x” with the typo. Regards, Yunus