public String transactionalProducerId() {
        return transactionalProducerId(groupId());
    }
@Test
    public void shouldConstructExpectedTransactionalId() {
        Map<String, String> workerProps = configs();

        workerProps.put(GROUP_ID_CONFIG, "why did i stay up all night writing unit tests");
        assertEquals(
                "connect-cluster-why did i stay up all night writing unit tests",
                new DistributedConfig(workerProps).transactionalProducerId()
        );

        workerProps.put(GROUP_ID_CONFIG, "connect-cluster");
        assertEquals(
                "connect-cluster-connect-cluster",
                new DistributedConfig(workerProps).transactionalProducerId()
        );

        workerProps.put(GROUP_ID_CONFIG, "\u2603");
        assertEquals(
                "connect-cluster-\u2603",
                new DistributedConfig(workerProps).transactionalProducerId()
        );
    }