@creese The round trip worked using the producer
and subscribe-consumer
functions but the KStreams API wasn't able to read from the topic when using the same serde. I'm still digging through it to figure out what might be the issue
that’s extremely strange
Can you push some code to a throw-away repo that exhibits this behavior? I’d like to get to the bottom of it.
@creese I realized what was wrong with it. I just realized the to
function also requires to pass in a key-serde
and value-serde
and that's what was causing the serialization issues. I just needed to specify an Avro serde for these. Sorry, it's my unfamiliarity with KStreams and the framework that caused the issue here. Although, I do wonder if there's a better way to represent this issue in the exception that was being thrown. Thanks for all the help!
Glad you were able to work it out. Feel free to create a PR or issue to address.