This item is moved to confluent google group. On Wed, Jul 6, 2016 at 6:25 AM, Philippe Derome <phder...@gmail.com> wrote:
> 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>* >> > >
