@Override
    public ExecuteContext after(ExecuteContext context) {
        if (handler != null) {
            handler.doAfter(context);
        }

        cacheKafkaConsumer(context);
        MarkUtils.removeMark();
        return context;
    }
@Test
    public void testAfter() {
        mockConsumer = Mockito.mock(KafkaConsumer.class);
        ExecuteContext context = ExecuteContext.forMemberMethod(mockConsumer, null, null, null, null);

        interceptor.after(context);

        KafkaConsumerWrapper wrapper = KafkaConsumerController.getKafkaConsumerCache()
                .get(mockConsumer.hashCode());
        Assert.assertNotNull(wrapper);
        Assert.assertEquals(mockConsumer, wrapper.getKafkaConsumer());
        Assert.assertEquals("default", wrapper.getApplication());
        Assert.assertEquals("default", wrapper.getService());
        Assert.assertEquals("default", wrapper.getZone());
        Assert.assertEquals("default", wrapper.getProject());
        Assert.assertEquals("", wrapper.getEnvironment());
        Assert.assertFalse(wrapper.isAssign());
        Assert.assertFalse(wrapper.getIsConfigChanged().get());
        Assert.assertEquals(new HashSet<>(), wrapper.getOriginalTopics());
        Assert.assertEquals(new HashSet<>(), wrapper.getOriginalPartitions());
        Assert.assertEquals(NetworkUtils.getMachineIp(), wrapper.getServerAddress());
    }