kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dayong <will...@gmail.com>
Subject Re: Error "Unknown magic byte" occurred while deserializing Avro message
Date Wed, 23 Nov 2016 12:27:53 GMT
As I remember this is to complain the fist byte of msg is not x00. I think console producer
does not support json since it uses string schema. 

Thanks,
Dayong

> On Nov 23, 2016, at 4:28 AM, ZHU Hua B <Hua.b.Zhu@alcatel-lucent.com> wrote:
> 
> Hi,
> 
> 
> We tried to produce and consume a AVRO message (zookeeper, broker and schema registry
have been launched), error "Unknown magic byte" occurred while deserializing Avro message,
if I missed anything? Thanks!
> 
> 
> From producer:
> # bin/kafka-avro-console-producer --broker-list localhost:9092 --topic test --property
value.schema='{"type":"record","name":"myrecord","fields":[{"name":"f1","type":"string"}]}'
> SLF4J: Class path contains multiple SLF4J bindings.
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/confluent-common/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/schema-registry/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
> SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
> 
> {"f1": "value1"}
> 
> 
> From consumer:
> # bin/kafka-avro-console-consumer --topic test --zookeeper localhost:2181 --from-beginning
> SLF4J: Class path contains multiple SLF4J bindings.
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/kafka-serde-tools/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/confluent-common/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: Found binding in [jar:file:/root/confluent/share/java/schema-registry/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
> SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
> 
> [2016-11-23 16:15:11,108] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$:103)
> org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message
for id -1
> Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
> [2016-11-23 16:15:11,108] ERROR Unknown error when running consumer:  (kafka.tools.ConsoleConsumer$:103)
> org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message
for id -1
> Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
> 
> 
> Best Regards
> 
> Johnny
> 

Mime
View raw message