📚 RDF Stream Validation Library
Turbine is a library that allows to validate RDF streams against a given schema.
// Turbine will connect to kafka at the given ip address and to the given topic.Turbine turbine = new Turbine(new KafkaConsumer("127.0.0.1", "rdf-streams-topic"),Validator.DEFAULT_SHACLEX_VALIDATOR);// Start turbineturbine.run();// Do whatever you want...// Will tear down the connection to kafka.turbine.stop();