class ProducerPropertiesFactory {

    Map<String, Object> getProducerProperties() {
        final HashMap<String, Object> producerProperties =
                configToProperties(kafkaConfig.getInternalProducerConfig().getConfig(KAFKA_CLIENTS_KEY));
        addMetadata(producerProperties);
        addSecurityProtocol(producerProperties);
        addSpecificConfig(producerProperties);
        return Collections.unmodifiableMap(producerProperties);
    }

    private  ProducerPropertiesFactory(final Connection connection, final KafkaConfig kafkaConfig);

}