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