[FLINK-7764] FlinkKafkaProducer010 does not accept name, uid, or parallelism

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.2, 1.4.0
• Fix Version/s: 1.3.4, 1.4.0
• Component/s: Connectors / Kafka
• Assignee: Xingcan Cui
• Reporter: Fabian Hueske
• Created: 05/Oct/17 12:32
• Updated: 12/Mar/18 15:42
• Resolved: 12/Mar/18 15:42

Description

As reported on the user list:

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.

Issue Links

• links to: GitHub Pull Request #4790
• links to: GitHub Pull Request #4819