Skip to content
Advertisement

Tag: avro

Nested arrays in Avro

I would like to store two-dimensional arrays of numbers in Avro. I have tried the following: But when I tried to read it with the parser: I get the following error: Answer It looks like you have one too many type keys. You schema should be this instead:

consuming Kafka Avro massages in Python

I am trying to consume messages from Kafka Avro in Python. We have it in Java, and it’s working, but when trying to consume it in the Jupyter notebook, Parsing does not work. I followed the example given by the documentation: (I’ve removed conf information for security reasons) This is the error I got: KafkaError{code=_KEY_DESERIALIZATION,val=-160,str=”‘str’ object is not callable”} It

Advertisement