THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public interface Serializer<T> extends Closeable {
void configure(Map<String, ?> configs, boolean isKey);
default byte[] serialize(String topic, T data) {
return null;
}
default byte[] serialize(String topic, Headers headers, T data) { // This is the new method
return serialize(topic, data);
}
@Override
void close();
} |
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public interface Deserializer<T> extends Closeable {
void configure(Map<String, ?> configs, boolean isKey);
default T deserialize(String topic, byte[] data) {
return null;
}
default T deserialize(String topic, Headers headers, byte[] data) { // This is the new method
return deserialize(topic, data);
}
@Override
void close();
} |
...