@Override
    public void addTransactionSubscription(ProxyContext ctx, String group, List<String> topicList) {
        for (String topic : topicList) {
            addTransactionSubscription(ctx, group, topic);
        }
    }
@Test
    public void testAddTransactionSubscription() {
        this.clusterTransactionService.addTransactionSubscription(ctx, GROUP, TOPIC);

        assertEquals(1, this.clusterTransactionService.getGroupClusterData().size());
        assertEquals(CLUSTER_NAME, this.clusterTransactionService.getGroupClusterData().get(GROUP).stream().findAny().get().getCluster());
    }