@Override
    public ExecuteContext after(ExecuteContext context) {
        KafkaConsumerWrapper kafkaConsumerWrapper = KafkaConsumerController.getKafkaConsumerCache()
                .get(context.getObject().hashCode());
        if (kafkaConsumerWrapper == null) {
            return context;
        }

        if (handler != null) {
            handler.doAfter(context);
        }

        KafkaConsumerController.removeKafkaConsumeCache(kafkaConsumerWrapper.getKafkaConsumer());
        LOGGER.info("Remove consumer cache after closing.");
        return context;
    }
@Test
    public void testAfter() {
        ExecuteContext context = ExecuteContext.forMemberMethod(mockConsumer, null, null, null, null);
        interceptor.after(context);
        Assert.assertEquals(0, KafkaConsumerController.getKafkaConsumerCache().values().size());
    }