    @Test
    public void processRequest_GetConsumerListByGroupAndTopic() throws Exception {

        ConsumerGroupInfo consumerGroupInfo = deFiBrokerController.getConsumerManager().getConsumerGroupInfo(group);
        assertThat(consumerGroupInfo).isNotNull();

        RemotingCommand request = GetConsumerListCommand();
        RemotingCommand response = deFiClientManageProcessor.processRequest(handlerContext, request);
        assertThat(response).isNotNull();
        assertThat(response.getCode()).isEqualTo(ResponseCode.SUCCESS);
        GetConsumerListByGroupResponseBody body = RemotingSerializable.decode(response.getBody(), GetConsumerListByGroupResponseBody.class);
        List<String> clientIdList = body.getConsumerIdList();
        assertThat(clientIdList).isNotNull();
        assertThat(clientIdList.get(0)).isEqualTo(clientId);
    }