You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@druid.apache.org by Cinto Sunny <ci...@gmail.com> on 2020/11/06 00:46:33 UTC

Custom extension in Druid

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

Re: Custom extension in Druid

Posted by Tijo Thomas <ti...@gmail.com>.
I will take a look at it . Can you share the  github link .

On Fri, Nov 6, 2020 at 6:36 AM Cinto Sunny <ci...@gmail.com> 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