add kafka+minio
This commit is contained in:
parent
d78f7d5ea2
commit
0a8635cab6
@ -266,7 +266,7 @@ spec:
|
||||
sasl.mechanism=PLAIN
|
||||
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='inter_broker_user' password='${inter_broker_password}';
|
||||
EOF
|
||||
kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
/opt/bitnami/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
--alter --add-config 'SCRAM-SHA-512=[password=${password}],SCRAM-SHA-256=[password=${password}]' \
|
||||
--entity-type users --entity-name '${username}'
|
||||
" >/dev/null
|
||||
@ -279,13 +279,13 @@ spec:
|
||||
[ -z "${topic_name}" ] && continue
|
||||
|
||||
kubectl -n kafka exec "${target_pod}" -c kafka -- /bin/bash -lc "\
|
||||
kafka-topics.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
/opt/bitnami/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
--create --if-not-exists --topic '${topic_name}' --partitions '${partitions}' --replication-factor '${replication_factor}'
|
||||
" >/dev/null
|
||||
|
||||
if [ -n "${topic_configs}" ]; then
|
||||
kubectl -n kafka exec "${target_pod}" -c kafka -- /bin/bash -lc "\
|
||||
kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
/opt/bitnami/kafka/bin/kafka-configs.sh --bootstrap-server localhost:9094 --command-config /tmp/admin.properties \
|
||||
--alter --entity-type topics --entity-name '${topic_name}' --add-config '${topic_configs}'
|
||||
" >/dev/null
|
||||
fi
|
||||
|
||||
Loading…
Reference in New Issue
Block a user