I will take a look at it . Can you share the github link .
On Fri, Nov 6, 2020 at 6:36 AM Cinto Sunny <[email protected]> wrote:
> 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
>
--
Thanks & Regards
Tijo Thomas
