Skip to content
This repository has been archived by the owner on Apr 22, 2022. It is now read-only.

Divolte-clickStream-kafka-KSQL #464

Open
mbsj6962 opened this issue Nov 23, 2020 · 2 comments
Open

Divolte-clickStream-kafka-KSQL #464

mbsj6962 opened this issue Nov 23, 2020 · 2 comments

Comments

@mbsj6962
Copy link

i'm trying to connect divolte to kafka but it always tels me :
ERROR Unknown error when running consumer: (kafka.tools.ConsoleConsumer$:46)
org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
and i can not parse key and value of divolte message

@josephwibowo
Copy link

josephwibowo commented Feb 10, 2021

if you're using Kafka from Confluent, you need to use the Schema Registry in order to deserialize the Avro messages.

@OneCricketeer
Copy link

Schema Registry can be used with any Kafka, not only the one provided by Confluent Platform, but yes, the error is related to incorrect usage of some serializer/deserializer combo

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants