nice! related, we just added similar capability to librdkafka (the C client) to facilitate better integration testing. hopefully we will expose it in the bindings as well at some point.