Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Integration tests were originally used within generator project as inline compiling was not supported by Fluxtion. Many tests have been migrated to use com.fluxtion.generator.util.MultipleSepTargetInProcessTest.
MultipleSepTargetInProcessTest has the following advantages:
Supports in-process compiling no need for integration tests
Parameterized to test both compiled and interpreted v
This is the repository of the ElasTest Monitoring Service, which provides a monitoring infrastructure suitable for inspecting executions of a SuT (System under Test) and the ElasTest platform itself online.
Integration tests were originally used within generator project as inline compiling was not supported by Fluxtion. Many tests have been migrated to use com.fluxtion.generator.util.MultipleSepTargetInProcessTest.
MultipleSepTargetInProcessTest has the following advantages: