flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Kafka Producer writeToKafkaWithTimestamps; name, uid, parallelism fails
Date Thu, 05 Oct 2017 12:33:37 GMT
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 <yunolgun@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

Mime
View raw message