Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Won't Fix
-
None
-
None
-
None
-
None
Description
So, it seems that if I want to set a custom serializer class on the producer (in 0.8), I have to use a class that includes a special constructor like:
public class MyKafkaEncoder<MyType> implements Encoder<MyType> {
// This constructor is expected by the kafka producer, used by reflection
public MyKafkaEncoder(VerifiableProperties props)
@Override
public byte[] toBytes(MyType message)
}
It seems odd that this would be a requirement when implementing an interface. This seems not to have been the case in 0.7.
What could my encoder class do with the VerifiableProperties?