jinja config files

This commit is contained in:
m0duspwnens
2024-04-09 11:07:53 -04:00
parent d38051e806
commit bd5fe43285
4 changed files with 4 additions and 21 deletions

View File

@@ -1,8 +0,0 @@
{% from 'vars/globals.map.jinja' import GLOBALS %}
{% from 'kafka/map.jinja' import KAFKAMERGED %}
{% set KAFKACONFIG = {} %}
{% for k, v in KAFKAMERGED.config.items() %}
{% do KAFKACONFIG.update({k | replace("_x_", "."): v}) %}
{% endfor %}

View File

@@ -10,16 +10,8 @@
{% set kafka_ips_logstash = [] %}
{% set kafka_ips_kraft = [] %}
{% set kafkanodes = salt['pillar.get']('kafka:nodes', {}) %}
{% set kafka_nodeid = salt['pillar.get']('kafka:nodes:' ~ GLOBALS.hostname ~ ':nodeid') %}
{% set kafka_ip = GLOBALS.node_ip %}
{% set nodes = salt['pillar.get']('kafka:nodes', {}) %}
{% set combined = [] %}
{% for hostname, data in nodes.items() %}
{% do combined.append(data.nodeid ~ "@" ~ hostname ~ ":9093") %}
{% endfor %}
{% set kraft_controller_quorum_voters = ','.join(combined) %}
{# Create list for kafka <-> logstash/searchnode communcations #}
{% for node, node_data in kafkanodes.items() %}
{% do kafka_ips_logstash.append(node_data['ip'] + ":9092") %}
@@ -32,7 +24,6 @@
{% endfor %}
{% set kraft_server_list = "','".join(kafka_ips_kraft) %}
include:
- ssl

View File

@@ -1,2 +1,2 @@
{% from 'kafka/config.map.jinja' import KAFKACONFIG -%}
{{ KAFKACONFIG.client | yaml(False) }}
{% from 'kafka/map.jinja' import KAFKAMERGED -%}
{{ KAFKAMERGED.config.client | yaml(False) | replace("_x_", ".") }}

View File

@@ -1,2 +1,2 @@
{% from 'kafka/config.map.jinja' import KAFKACONFIG -%}
{{ KAFKACONFIG.server | yaml(False) }}
{% from 'kafka/map.jinja' import KAFKAMERGED -%}
{{ KAFKAMERGED.config.server | yaml(False) | replace("_x_", ".") }}