public KafkaConfiguration getConfiguration() {
        return configuration;
    }
@Test
    public void testCreateAdditionalPropertiesResolvePlaceholders() {
        context.getPropertiesComponent().addOverrideProperty("foo", "123");
        context.getPropertiesComponent().addOverrideProperty("bar", "test");

        final String uri
                = "kafka:mytopic?brokers=broker1:12345,broker2:12566&partitioner=com.class.Party&additionalProperties.extra.1={{foo}}&additionalProperties.extra.2={{bar}}";

        KafkaEndpoint endpoint = context.getEndpoint(uri, KafkaEndpoint.class);
        assertEquals("broker1:12345,broker2:12566", endpoint.getConfiguration().getBrokers());
        assertEquals("mytopic", endpoint.getConfiguration().getTopic());
        assertEquals("com.class.Party", endpoint.getConfiguration().getPartitioner());
        assertEquals("123", endpoint.getConfiguration().getAdditionalProperties().get("extra.1"));
        assertEquals("test", endpoint.getConfiguration().getAdditionalProperties().get("extra.2"));

        // test properties on producer keys
        final Properties producerProperties = endpoint.getConfiguration().createProducerProperties();
        assertEquals("123", producerProperties.getProperty("extra.1"));
        assertEquals("test", producerProperties.getProperty("extra.2"));

        // test properties on consumer keys
        final Properties consumerProperties = endpoint.getConfiguration().createConsumerProperties();
        assertEquals("123", consumerProperties.getProperty("extra.1"));
        assertEquals("test", consumerProperties.getProperty("extra.2"));
    }