Hello kafka community, fixed it with toTable(materialized).. On Fri, 25 Sep 2020 at 10:49, Dumitru-Nicolae Marasoui < [email protected]> wrote:
> Hello kafka community, > I checked in debug that the serializer is KafkaAvroSerializer, like it > should be. > So in KStreamImpl.to(TopicNameExtractor<K, V> topicExtractor, > ProducedInternal<K, V> produced) I checked that the serializer is avro. > > However here is the exception i receive: > > "ClassCastException while producing data to a sink topic. > > A serializer (key: org.apache.kafka.common.serialization.ByteArraySerializer > / value: org.apache.kafka.common.serialization.ByteArraySerializer) > > is not compatible to the actual key or value type (key type: > com.ovoenergy.global.ContractKey / value type: > com.ovoenergy.global.ContractValue). Change the default Serdes in > StreamConfig or provide correct Serdes via method parameters (for example if > using the DSL, `#to(String topic, Produced<K, V> produced)` with > `Produced.keySerde(WindowedSerdes.timeWindowedSerdeFrom(String.class))`)." > > Thank you > -- > > Dumitru-Nicolae Marasoui > > Software Engineer > > > 140-142, Kensington Church Street, London, W8 4BN > > w kaluza.com <https://www.kaluza.com/> > > LinkedIn <https://www.linkedin.com/company/kaluza> | Twitter > <https://twitter.com/Kaluza_tech> > > Kaluza Ltd. registered in England and Wales No. 08785057 > > VAT No. 100119879 > > Help save paper - do you need to print this email? > > -- Dumitru-Nicolae Marasoui Software Engineer 140-142, Kensington Church Street, London, W8 4BN w kaluza.com <https://www.kaluza.com/> LinkedIn <https://www.linkedin.com/company/kaluza> | Twitter <https://twitter.com/Kaluza_tech> Kaluza Ltd. registered in England and Wales No. 08785057 VAT No. 100119879 Help save paper - do you need to print this email?
