You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Yunus Olgun <yu...@gmail.com> on 2017/10/05 11:38:35 UTC

Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails

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

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

Posted by Fabian Hueske <fh...@gmail.com>.

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 <yu...@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