Please ignore until I become quite more specific about my code usage (will try to recover the same code I used). In the mean time, I managed to serialize into output topic using a JsonSerde, which was straightforward.
On Wed, Jul 6, 2016 at 5:26 AM, Michael Noll <mich...@confluent.io> wrote: > Phil, > > > I then specify a Serde<GenericRecord> (new GenericAvroSerde) as value > > deserializer when outputting to topic via table.to method. > > I suppose that was a typo, and you actually meant "as a value > *serializer*", right? > > > > On Tue, Jul 5, 2016 at 11:55 PM, Philippe Derome <phder...@gmail.com> > wrote: > > > This is possibly more of a Confluent question as GenericAvroSerde is in > > Confluent example code base. > > > > I have a small Stream application, which creates a KTable with String key > > and GenericRecord value. > > > > I then specify a Serde<GenericRecord> (new GenericAvroSerde) as value > > deserializer when outputting to topic via table.to method. > > > > I get a NPE on deserializing with this.schemaRegistry being null within > > AbstractKafkaAvroSerializer#serializeImpl. > > > > Could it be simply that GenericRecords are more of an intermediate class > > and are not meant to be serialised? > > > > I'd like to stream the values on topic as GenericRecord. I thought it > > should work. Alternatively, guidance on using SpecificAvroSerde would be > > very helpful. > > > > > > -- > Best regards, > Michael Noll > > > > *Michael G. Noll | Product Manager | Confluent | +1 650.453.5860Download > Apache Kafka and Confluent Platform: www.confluent.io/download > <http://www.confluent.io/download>* >
