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.
Current state: Under Discussion
Vote thread: https://lists.apache.org/thread/jsy1ld5f6b6k8qcjzpy5k08ropqd4dd1
Discussion thread: https://lists.apache.org/thread/n3k6vb4vddl1s5nopcyglnddtvzp4j63
JIRA: KAFKA-16796
We are going to move all tools-related code from core module (scala) to tools module (java) in 4.0. kafka.serializer.Decoder is a public APIs and it is in core module. Hence we need to introduce replacement to deprecate it in 3.8.0
The new java interface org.apache.kafka.tools.api.Decoder is shown below. It is located at tools-api module, since it must be accessible by core module.
@FunctionalInterface
public interface Decoder<T> {
T fromBytes(byte[] bytes);
} |
The old scala trait will extend the new java interface with deprecated annotation
@deprecated(since = "3.8.0")
trait Decoder[T] {
def fromBytes(bytes: Array[Byte]): T
} |
org.apache.kafka.tools.api.Decoder to replace scala trait kafka.serializer.Decoderkafka.serializer.DefaultDecoder, kafka.serializer.StringDecoder, kafka.serializer.LongDecoder, and kafka.serializer.IntegerDecoder org.apache.kafka.tools.api.Decoder. They have same method, but the new constructor does not accept VerifiableProperties. Hence, users' custom decoders have to offer default constructor The new unit test used to verify the "warning messages" about deprecated kafka.serializer.Decoder will be added. The messages are used to encourage users to adopt the new interface
N/A