Martin Sillence

So from what I can see `slots` in the `live` queue migrate into thread locals and then we have no global visibility of them The connection may not be activly...

> A slot that is claimed from a thread local (TLR_CLAIMED) will already be in the live queue. Hence this is a separate state, and also why releasing such claims...

I'd suggest adding: `prompt=false` to your url

I've rebased so hopefully there is one clean commit with the right message now

It is possible to use the XmlMapper with a JacksonXmlAnnotationIntrospector to get the same effect as jaxb and XmlSchema with package level namespaces: ``` XmlMapper mapper = new XmlMapper(); mapper.setAnnotationIntrospector(new...

Sorry been a bit snowed under there is also info here https://stackoverflow.com/a/52304789 the core concept is to send a message then wait for a week default or 45 mins with...

Thanks for the quick reply, is it possible to start up the kafka container once for all the tests? Is there some overall test lifecycle listener option? It seems when...

that's fantastic, thank you. do you want to close this or should we keep this open as a reminder to update the docs?

I've tried setting key.subject.name.strategy with my own class and I see it in the config but I don't see where that's used in the code nor do I see it...

from my understanding of the code, the class AbstractKafkaAvroDeserializer.getSpecificReaderSchema calls the SpecificData.getClass I can see AbstractKafkaSchemaSerDeConfig.keySubjectNameStrategy being called and having the new class I've configured, that sets the AbstractKafkaSchemaSerDe.keySubjectNameStrategy and...