Custom extension in Druid

[Cinto Sunny]

Hey Team,

I am trying to write a new custom extension in Druid. I have followed all
the guidelines like writing the plugin, copying the jar (to
dist/druid/extensions), adding to loadList. The loadList seems to be picked
up, but I am getting the following error:

Caused by: com.fasterxml.jackson.databind.exc.ValueInstantiationException:
Cannot construct instance of
`com.XXXX.druid.parser.ABCEnvelopeInputRowParser`, problem: Invalid value
org.apache.kafka.common.serialization.ByteArrayDeserializer for
configuration XXX.YYYY.envelope.payload.deserializer: Class
org.apache.kafka.common.serialization.ByteArrayDeserializer could not be
found.

This is being set here -- ABCEnvelopeInputRowParser file:

public ABCEnvelopeInputRowParser(
            @JsonProperty("parseSpec") ParseSpec parseSpec,
            @JsonProperty("tables") String tables,
            @JsonProperty("topic") String topic
    ) {
...
        Map<String, String> configs = new HashMap<>();
        configs.put("XXX.YYYY.envelope.payload.deserializer",
"*org.apache.kafka.common.serialization.ByteArrayDeserializer*");

I can provide further info if needed. Thanks for the help.

- Cinto