node/etc/examples/nodes/kafka.conf at 80db91e3f4ae212b22f910aaecc53c6ad47bce00 · VILLASframework/node · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
# SPDX-FileCopyrightText: 2014-2023 Institute for Automation of Complex Power Systems, RWTH Aachen University
# SPDX-License-Identifier: Apache-2.0

nodes = {
    kafka_node = {
        type = "kafka"

        format = "json.kafka"

        server = "localhost:9092"
        protocol = "PLAINTEXT"
        client_id = "villas-node"

        in = {
            topic = "test-topic"
            group_id = "villas-node"
        }

        out = {
            topic = "test-topic"
        }
    }

    siggen = {
        type = "signal"

        rate = 20
        values = 5
        signal = "mixed"
    }
}

paths = (
    {
        in = "siggen"
        out = "kafka_node"
    },
    {
        in = "kafka_node"

        hooks = [
            "print"
        ]
    }
)