Antony Stubbs

@ephemient that seems great! Perhaps the two could be merged to enable both options... @cpovirk have you seen #706 ?

hi @gwaramadze ! Thanks for the compliment! I'm the author of the parallel consumer project :) Let me know how I can help, or if you have any ideas for...

Something like: ``` class ReflectionConstructor implements ObjectFactory { @Override public T createInstance(Class type, RandomizerContext context) { return (T) constructReflection(type, context); } @SneakyThrows private Object constructReflection(Class type, RandomizerContext context) { Constructor...

` this.seek(topicPartition, offset + 1); // partition and offset retrieved from exception instance ` BTW - this is incorrect - it assumes only a single record was polled from the...

FYI just pushed #470 - this works fine as far as I can see, as expected. But using MockConsumer is difficult (because it's not a complete implementation). Use LongPollingMockConsumer instead....

done in #452

This only contained some minor doc changes, which are now anyway merged through other means. See retry-exception, retry-exception-simple and retry-exception-w-terminal branches.

Will not do, soon PC will get migrated to Confluent's public semaphore.

@fowlerp-qlik do you specifically want to be informed of connection state changes, or is it enough to have the state exposed through metrics / health check?

I've also just realised that AK consumer doesn't actually expose this either. We will be adding metrics very soon, let's see if that will be enough. Otherwise, we can also...