Hi All, I’m new to streaming avro records and am parsing Avro from a Kafka
direct stream with spark streaming 2.1.1, I was wondering if anyone could
please suggest an API for decoding Avro records with Scala? I’ve found
KafkaAvroDecoder, twitter/bijection and the Avro library, each seem to
You might also enable debug in: hadoop-env.sh
# Extra Java runtime options. Empty by default.
export HADOOP_OPTS=$HADOOP_OPTS -Djava.net.preferIPv4Stack=true
-Dsun.security.krb5.debug=true ${HADOOP_OPTS}”
and check that the principals are the same on the NameNode and DataNode.
and you can
