class ConsumeKafkaRecord_0_10 extends AbstractProcessor {

    @OnStopped
    public void close() {
        final ConsumerPool pool = consumerPool;
        consumerPool = null;
        if (pool != null) {
            pool.close();
        }
    }

}