THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
| Code Block | ||
|---|---|---|
| ||
default void configure(Map<String, ?> configs, boolean isKey) {
// intentionally left blank
}
default void close() {
// intentionally left blank
} |
...
| Code Block | ||
|---|---|---|
| ||
@FunctionalInterface
public interface Serializer<T> extends Closeable {
default void configure(Map<String, ?> configs, boolean isKey) {
// intentionally left blank
}
default void close() {
// intentionally left blank
}
} |
...
| Code Block | ||
|---|---|---|
| ||
@FunctionalInterface
public interface Deserializer<T> extends Closeable {
default void configure(Map<String, ?> configs, boolean isKey) {
// intentionally left blank
}
default void close() {
// intentionally left blank
}
} |
...