...
When you start BaDaSt, a Zookepper server and a Kafka server are started. Kafka handles the preservation of incoming data stream elements per stream (each stream is a Kafka topic and every stream element has a Kafka offset). Zookeeper, Kafka and BaDaSt are configurable by a properties file within the Odysseus HOME folder (.odysseus). Once BaDaSt is running, you can control it from Odysseus with an Odysseus Script command, called BADASTRECORDER type=<type> source=<source>. The field type specifies the recorder that means a transport handler. The following code block contains all available recorders. The field source defines which data stream from which external source should be preserved. Note that you have to (1) define the source within the same script file and before the recorder command and (2) use the same name for the source as you do in the source definition in Odysseus.
| Code Block | ||||
|---|---|---|---|---|
| ||||
#BADASTRECORDER type=FileRecorder source=bid /// Use the FileRecorder, if the data source is a finite file (e.g., a CSV) #BADASTRECORDER type=TCPRecorder source bid /// Use the TCPRecorder, if the data source can be accessed by TCP. Host and port are taken from the source definition. |
...