/camel-kafka-activitystream-dataset

Primary LanguageJava

camel-kafka-activitystream-dataset

An implementation of camel-ldp that consumes an activity stream from Kafka and writes the events to a Jena dataset.

Build

$ gradle build
$ gradle docker

Configuration

  • org.trellisldp.camel.kafka.activitystream.cfg

  • Default dataset Location /mnt/activitystream-data

Docker

$ docker run -ti trellisldp/activitystream-dataset

Use With Trellis:

Fuseki Endpoint

  • This includes an embedded Fuseki instance
  • Read and query events at: http://localhost:3330/rdf/data?graph=http://trellisldp.org/activitystream

Example Query

  • Get Resource Subjects by Type (e.g. <http://iiif.io/api/presentation/2#Manifest>)
SELECT * WHERE {GRAPH <http://trellisldp.org/activitystream> 
{?s <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://iiif.io/api/presentation/2#Manifest>}}
$ curl -v http://localhost:3330/rdf/query?query=SELECT%20*%20WHERE%20%7BGRAPH%20%3Chttp%3A%2F%2Ftrellisldp.org%2Factivitystream%3E%20%7B%3Fs%20%3Chttp%3A%2F%2Fwww.w3.org%2F1999%2F02%2F22-rdf-syntax-ns%23type%3E%20%3Chttp%3A%2F%2Fiiif.io%2Fapi%2Fpresentation%2F2%23Manifest%3E%7D%7D