nodes = { kafka_node = { type = "kafka", format = "json.kafka", server = "localhost:9094", protocol = "SASL_SSL", client_id = "villas-node", in = { consume = "test-topic", group_id = "villas-node" }, out = { produce = "test-topic" }, ssl = { ca = "/etc/ssl/certs/ca.pem", }, sasl = { mechanisms = "SCRAM-SHA-512", username = "scram-sha-512-usr", password = "scram-sha-512-pwd" } } }