tree d9529f87587ad90bd9bcf15f00c8d72991818aae
parent 724fb3d8701a31349a1f65dee496d0a62916d0ed
author Fabian Paul <fabianpaul@ververica.com> 1631629575 +0200
committer Dawid Wysakowicz <dwysakowicz@apache.org> 1631649049 +0200

[FLINK-24282][connectors/kafka] Make topic selector for KafkaSink serializable

It is possible to calculate the target topic per record. Therefore users
can provide a lambda when constructing the KafkaSink. Before this
commit the lambda was not marked as serializable and could not be
transferred to the workers.