Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

fixes

Browse source
This commit is contained in:
Steffen Vogel 2021-06-21 16:53:28 -04:00
parent 2d1e8d17ce
commit 6aaddf2086
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/nodes/kafka.cpp
View file

@ -580,13 +580,12 @@ static struct vnode_type p;
__attribute__((constructor(110)))
static void register_plugin() {
p.name = "kafka";
p.description = "Kafka event message streaming (rdkafka)";
p.instances.state = State::DESTROYED;
p.name = "kafka";
p.description = "Kafka event message streaming (rdkafka)";
p.vectorize = 0;
p.size = sizeof(struct kafka);
p.start = kafka_type_start;
p.stop = kafka_type_stop;
p.type.start = kafka_type_start;
p.type.stop = kafka_type_stop;
p.destroy = kafka_destroy;
p.prepare = kafka_prepare;
p.parse = kafka_parse;