Page History

...

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> sourcesourcename=<source> viewname=<view>. The field type specifies the recorder that means a transport handler. The following code block contains all available recorders. The field source defines fields sourcename and viewname define 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 and view as you do in the source definition in Odysseus.

#BADASTRECORDER type=FileRecorder source sourcename=nexmark.bid viewname=bid	/// Use the FileRecorder, if the data source is a finite file (e.g., a CSV)
#BADASTRECORDER type=TCPRecorder source bidourcename=nexmark.bid viewname=bid			/// Use the TCPRecorder, if the data source can be accessed by TCP. Host and port are taken from the source definition.

...