public KafkaClientSupplier getKafkaClientSupplier() {
        return getConfiguredInstance(StreamsConfig.DEFAULT_CLIENT_SUPPLIER_CONFIG,
            KafkaClientSupplier.class);
    }
@Test
    public void shouldReturnDefaultClientSupplier() {
        final KafkaClientSupplier supplier = streamsConfig.getKafkaClientSupplier();
        assertInstanceOf(DefaultKafkaClientSupplier.class, supplier);
    }