...

This page is meant as a template for writing a KIP. To create a KIP choose Tools->Copy on this page and modify with your content and replace the heading with the next KIP number and a description of your issue. Replace anything in italics with your own description.

Status

Current state: Under Discussionadopt

Discussion thread: here

Vote: here

...

In org.apache.kafka.common.serialization.Serde, org.apache.kafka.common.serialization.Serializer and org.apache.kafka.common.serialization.Deserializer, we will add empty implementations to close() and configure(). Also, we will add the annotation "FunctionalInterface" to Deserializer and Serializer.

default void configure(Map<String, ?> configs, boolean isKey) {
  // intentionally left blank
}
default void close() {
  // intentionally left blank
}

...

@FunctionalInterface
public interface Serializer<T> extends Closeable {
 default void configure(Map<String, ?> configs, boolean isKey) {
    // intentionally left blank
  }
  default void close() {
    // intentionally left blank
  }
}

...

@FunctionalInterface
public interface Deserializer<T> extends Closeable {
  default void configure(Map<String, ?> configs, boolean isKey) {
    // intentionally left blank
  }
  default void close() {
    // intentionally left blank
  }
}

...