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:

• Start trellis-compose

• Start camel-integration-compose

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