Produce SBP streams over Kafka, consume it and analyze on demand.
brew install openssl zookeeper kafka librdkafka;
stack init;
stack build;
Open two terminals. In the first,
./scripts/start_zookeeper.sh;
./scripts/add_example_topic.sh;
In the second,
stack run;
- Send different SBP messages to 2 different topics & consume.
- Calculate e.g. min error live by sending only position.
- Build reader monad that can be sent as a kafka message containing workflow ID, Piksi ID, or Piksi Run ID. This makes wrapping relevant SBP cleaner.
- Read from topic, get ^^ monad contents, and do a basic gnss-analysis over a piksi run.
At this point, the repo is a fork of [https://github.com/haskell-works/hw-kafka-client]