THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Under Discussion [One of "Under Discussion", "Accepted", "Rejected"] Accepted (vote thread)
Discussion thread: here
JIRA: KAFKA-6923
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public interface Serializer<T> extends Closeable { void configure(Map<String, ?> configs, boolean isKey); default byte[] serialize(String topic, T data); 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); default T deserialize(String topic, Headers headers, byte[] data) { // This is the new method return deserialize(topic, data); } @Override void close(); } |
...