Refactoring of FlinkKafkaProducer

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Refactoring of FlinkKafkaProducer

Александр
Hello, flink community! I recently joined the community and I'm trying to
understand the project module by module. I've noticed that in
FlinkKafkaProducer (
*https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java
<https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java>*
)
we have about ~ 8 constructors. Maybe we can use builder pattern here? It
seems the better solution. However, we have to keep our constructors for
backward compatibility (but mark it deprecated I think).

What do you think about this idea?

BR,
Aleksandr Salatich