Thanks!
On Wed, May 18, 2016 at 12:38 PM, Fred Patton wrote:
> Thanks, Guozhang, I'll file a JIRA this afternoon. --Fred
>
> On Wed, May 18, 2016 at 11:51 AM, Guozhang Wang
> wrote:
>
> > Fred,
> >
> > You are right, only default serdes provided through configs are
> > auto-configured today. Bu
Thanks, Guozhang, I'll file a JIRA this afternoon. --Fred
On Wed, May 18, 2016 at 11:51 AM, Guozhang Wang wrote:
> Fred,
>
> You are right, only default serdes provided through configs are
> auto-configured today. But we could auto-configure other serdes passed
> along side the topology builder
Fred,
You are right, only default serdes provided through configs are
auto-configured today. But we could auto-configure other serdes passed
along side the topology builder as well. Do you want to file a JIRA to keep
track of this?
Guozhang
On Wed, May 18, 2016 at 11:36 AM, Fred Patton wrote:
Thanks, so much, Guozhang. It didn't work immediately when I tried end of
day, so I deferred til this morning. It seems I also needed to invoke
configure manually, or pass the props to the deserializer constructor. I am
providing the revised example in case it helps any one. Thank you Liquan
for po
Hi Fred,
You probably need to cast the configs to Map before adding
the specific.avro.reader config.
Thanks,
Liquan
On Tue, May 17, 2016 at 5:29 PM, Guozhang Wang wrote:
> Hello Fred,
>
> Thanks for reporting this. I looked through your code and found this is due
> to a bug in io.confluent.exa
Hello Fred,
Thanks for reporting this. I looked through your code and found this is due
to a bug in io.confluent.examples.streams.utils.SpecificAvroDeserializer.
I will fix this bug in Confluent's repo, as for you to work around it, you
can create your own SpecificAvroDeserializer with the correc
Before, switching the example from to() to through() things seemed to work
fine. Afterward, I get ClassCastExceptions from GenericRecord to
SpecificRecord. Hopefully, someone can point out something quick and dumb
so I can get my demo wrapped up. I never get past the through() method. I
am using th
