Hi all! While implementing a new custom flink serialization schema that wraps an existing Kafka serializer, I realized we are missing 2 key methods that could be easily added:
void configure(java.util.Map<java.lang.String,?> configs); void close(); We could rename configure to open but Kafka serializers have a configure method. The configure method would be called when the operator start with the provided kafka properties and the close when it shuts down. Currently there is no way to access the properties from the schema interfaces or close the schema on failure. This would be a very simple addition and could be added as optional methods to the interface to not break any schemas that are implemented as lambdas. What do you think? Gyula
