Streamer uses KafkaW
Created by: michele-brambilla
This PR introduces two main changes
- the
streamer
now usesKafkaW
instead of librdkafka; - the
connect()
task is now executed in task-based parallelism instead of thread-based;
and a new feature
- added tests for the
Streamer
.
Consequences:
- makes the filewriter implementation more uniform.
KafkaW
is the only explicit connection with librdkafka; - let us remove explicit locks and condition variables. The flow is now more linear;
- needs the fake librdkafka implementation to be specified using
-DFAKE_RDKAFKA=<path>
when invokingcmake
.