diff options
Diffstat (limited to 'src/main/docker/include/etc/confluent/docker/kafka.properties.template')
-rw-r--r-- | src/main/docker/include/etc/confluent/docker/kafka.properties.template | 19 |
1 files changed, 16 insertions, 3 deletions
diff --git a/src/main/docker/include/etc/confluent/docker/kafka.properties.template b/src/main/docker/include/etc/confluent/docker/kafka.properties.template index 242e393..5eeaea3 100644 --- a/src/main/docker/include/etc/confluent/docker/kafka.properties.template +++ b/src/main/docker/include/etc/confluent/docker/kafka.properties.template @@ -7,14 +7,27 @@ 'KAFKA_GC_LOG_OPTS', 'KAFKA_LOG4J_ROOT_LOGLEVEL', 'KAFKA_LOG4J_LOGGERS', - 'KAFKA_TOOLS_LOG4J_LOGLEVEL'] + 'KAFKA_TOOLS_LOG4J_LOGLEVEL', + 'KAFKA_ZOOKEEPER_CLIENT_CNXN_SOCKET'] -%} + +{# properties that don't fit the standard format #} +{% set other_props = { + 'KAFKA_ZOOKEEPER_CLIENT_CNXN_SOCKET' : 'zookeeper.clientCnxnSocket' + } -%} + {% set kafka_props = env_to_props('KAFKA_', '', exclude=excluded_props) -%} -{% for name, value in kafka_props.iteritems() -%} +{% for name, value in kafka_props.items() -%} {{name}}={{value}} {% endfor -%} +{% for k, property in other_props.items() -%} +{% if env.get(k) != None -%} +{{property}}={{env[k]}} +{% endif -%} +{% endfor -%} + {% set confluent_support_props = env_to_props('CONFLUENT_SUPPORT_', 'confluent.support.') -%} -{% for name, value in confluent_support_props.iteritems() -%} +{% for name, value in confluent_support_props.items() -%} {{name}}={{value}} {% endfor -%} |