zing
> >> > Avro message for id 7
> >> > Caused by: java.lang.NullPointerException
> >> > at
> >> > io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer
> >> .deserialize(AbstractKafkaAvroDeserializer.java:120)
> >> >
y
> happen, so your observation is a bit weird to me. Could your add a log
> entry in the `configure` function which constructs the registry client to
> make sure it is indeed triggered when the streams app start up?
>
>
> Guozhang
>
>
>
> On Fri, Sep 16, 2016 at 2:27 PM, W
Guozhang,
Any clues on this one?
Walter
On Wed, Sep 14, 2016 at 9:46 PM, Walter rakoff
wrote:
> Guozhang,
>
> I am using 0.10.0.0. Could the below log be the cause?
>
> 16/09/14 17:24:35 WARN ConsumerConfig: The configuration
> schema.registry.url = http://192.168.50.6: &l
ough config
> to NOT being configured when constructed:
> https://issues.apache.org/jira/browse/KAFKA-3639
>
>
> Which is fixed in the 0.10.0.0 release, which means you will only hit it if
> you are using the tech-preview release version.
>
>
> Guozhang
>
>
> On Wed,
Hello,
I get the below exception when deserilaizing avro records
using KafkaAvroDeserializer.
16/09/14 17:24:39 INFO StreamThread: Stream thread shutdown complete
[StreamThread-1]
Exception in thread "StreamThread-1"
org.apache.kafka.common.errors.SerializationException:
Error deserializing Avro
Hello,
I'm trying a sample Kafka Streams program in Scala.
val clickRecordKStream: KStream[String, ClickRecord] =
kStreamBuilder.stream(stringSerde, stringSerde, "test-topic")
.map( (k:String, v:String) => (k, ClickRecord(v)))
The map call throws error "type mismatch; found : (St
