Mark Tinsley

Hi all, any update on this? Happy to help out if I can.

This is quite a common pattern, we opted for having a list of predicates as you tend to want to check multiple things before moving on, so `[stream topic &...

So to get this to work on the current setup, you need to do something like: ``` clojure (doto (.serializer (avro/serde schema-url schema false)) (.configure {"schema.registry.url" schema-url "value.subject.name.strategy" "SubjectNamingStrategy"} false))...

@creese with Clojure spec if your map contains keys it would apply the spec against the key (if it has a spec for the key of course). ```clojure (s/def ::name...

Any news on this? Looks like the netty libs have moved on further to worth bumping up again and getting a release cut

Yeah tried without grep, same results. It's a bit random that on some runs it will show the message and on others it won't. The times when it does show...

Yes they all have the same avro schema, and we have no exit criteria we just wait for 10 seconds or so after seeing the Reached end of topic message...

ah nice, I'll give that a go

Yep this fixed it for me too!

I'm also having this issue, any update on a work around?