Re: Scala : ClassCastException with Kafka Connector and ObjectNode

2021-03-30 Thread Lehuede sebastien
Hi Till, That solved my issue ! Many many thanks for the solution and for the useful StackOverflow link ! ☺️ Cheers, Sébastien > Le 30 mars 2021 à 18:16, Till Rohrmann a écrit : > > Hi Sebastien, > > I think the Scala compiler infers the most specific type for deepCopy() which > is Nothing

Re: Scala : ClassCastException with Kafka Connector and ObjectNode

2021-03-30 Thread Till Rohrmann
Hi Sebastien, I think the Scala compiler infers the most specific type for deepCopy() which is Nothing (Nothing is the subtype of every type) [1] because you haven't specified a type here. In order to make it work you have to specify the concrete type: event.get("value").deepCopy[ObjectNode]() [

Scala : ClassCastException with Kafka Connector and ObjectNode

2021-03-30 Thread Lehuede sebastien
Hi all, I’m currently trying to use Scala to setup a simple Kafka consumer that receive JSON formatted events and then just send them to Elasticsearch. This is the first step and after I want to add some processing logic. My code works well but interesting fields form my JSON formatted events