Re: Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails

2017-10-05 Thread Fabian Hueske
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 : > Hi, > > I am using Flink 1.3.2. When I try to use KafkaProducer with timestamps it > fail

Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails

2017-10-05 Thread Yunus Olgun
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 producer = FlinkKafkaProducer010 .writeToKafkaWithTimestamps(stream, topicName, schema