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();
} |
...
Review existing unit tests and system tests.
Manual verification of binary compatibility: existing ExtendedSerializer implementations should work without recompiling the application.
Rejected Alternatives
The code examples here are made with the Deserializer class but they are completely valid for the Serializer as well.
...