Hi Yunus, thanks for reporting this problem. I opened the JIRA issue FLINK-7764 [1] for this.
Thanks, Fabian [1] https://issues.apache.org/jira/browse/FLINK-7764 2017-10-05 13:38 GMT+02:00 Yunus Olgun <yunol...@gmail.com>: > 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
