[KAFKA-1049] Encoder implementations are required to provide an undocumented constructor.

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Won't Fix
• Assignee: Unassigned
• Reporter: Jason Rosenberg
• Created: 07/Sep/13 06:23
• Updated: 04/Apr/15 22:02
• Resolved: 04/Apr/15 22:02

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)

{ // what can I do with this? }

@Override
public byte[] toBytes(MyType message)

{ return message.toByteArray(); }

}

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?