Re: KafkaProducer with generic (Avro) serialization schema

2018-05-02 Thread Wouter Zorgdrager
t; >>> Thanks, >>> Wouter >>> >>> Op do 26 apr. 2018 om 00:42 schreef Nortman, Bill < >>> william.nort...@pimco.com>: >>> >>>> The things I would try would first in you are you class Person and >>>>

Re: KafkaProducer with generic (Avro) serialization schema

2018-05-02 Thread Fabian Hueske
an, Bill < >> william.nort...@pimco.com>: >> >>> The things I would try would first in you are you class Person and >>> Address have getters and setters and a no argument constructor. >>> >>> >>> >>> *From:* Wouter Zorgdrager [ma

Re: KafkaProducer with generic (Avro) serialization schema

2018-05-02 Thread Aljoscha Krettek
com>>: >> The things I would try would first in you are you class Person and Address >> have getters and setters and a no argument constructor. >> >> >> >> From: Wouter Zorgdrager [mailto:zorgdrag...@gmail.com >> <mailto:zorgdrag...@gmail.com>]

Re: KafkaProducer with generic (Avro) serialization schema

2018-05-02 Thread Piotr Nowojski
gt; > > > From: Wouter Zorgdrager [mailto:zorgdrag...@gmail.com > <mailto:zorgdrag...@gmail.com>] > Sent: Wednesday, April 25, 2018 7:17 AM > To: user@flink.apache.org <mailto:user@flink.apache.org> > Subject: KafkaProducer with generic (Avro) serialization schema

Re: KafkaProducer with generic (Avro) serialization schema

2018-05-01 Thread Wouter Zorgdrager
gt;> >> >> >> *From:* Wouter Zorgdrager [mailto:zorgdrag...@gmail.com] >> *Sent:* Wednesday, April 25, 2018 7:17 AM >> *To:* user@flink.apache.org >> *Subject:* KafkaProducer with generic (Avro) serialization schema >> >> >> >> Dear

Re: KafkaProducer with generic (Avro) serialization schema

2018-04-26 Thread Wouter Zorgdrager
Zorgdrager [mailto:zorgdrag...@gmail.com] > *Sent:* Wednesday, April 25, 2018 7:17 AM > *To:* user@flink.apache.org > *Subject:* KafkaProducer with generic (Avro) serialization schema > > > > Dear reader, > > > > I'm currently working on writing a Kafk

RE: KafkaProducer with generic (Avro) serialization schema

2018-04-25 Thread Nortman, Bill
The things I would try would first in you are you class Person and Address have getters and setters and a no argument constructor. From: Wouter Zorgdrager [mailto:zorgdrag...@gmail.com] Sent: Wednesday, April 25, 2018 7:17 AM To: user@flink.apache.org Subject: KafkaProducer with generic (Avro

KafkaProducer with generic (Avro) serialization schema

2018-04-25 Thread Wouter Zorgdrager
Dear reader, I'm currently working on writing a KafkaProducer which is able to serialize a generic type using avro4s. However this serialization schema is not serializable itself. Here is my code for this: The serialization schema: class AvroSerializationSchema[IN : SchemaFor : FromRecord: ToReco