Code Review
/
dmaap
/
kafka11aaf.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
[DMAAP-KAFKA] Kafka Upgrade
[dmaap/kafka11aaf.git]
/
src
/
main
/
docker
/
include
/
etc
/
confluent
/
docker
/
kafka.properties.template
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
(file)
--- 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_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) -%}
{% set kafka_props = env_to_props('KAFKA_', '', exclude=excluded_props) -%}
-{% for name, value in kafka_props.ite
rite
ms() -%}
+{% for name, value in kafka_props.items() -%}
{{name}}={{value}}
{% endfor -%}
{{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.') -%}
{% set confluent_support_props = env_to_props('CONFLUENT_SUPPORT_', 'confluent.support.') -%}
-{% for name, value in confluent_support_props.ite
rite
ms() -%}
+{% for name, value in confluent_support_props.items() -%}
{{name}}={{value}}
{% endfor -%}
{{name}}={{value}}
{% endfor -%}