An implementation of camel-ldp that consumes an activity stream from Kafka and writes the events to an Elasticsearch Index.
$ gradle build
$ gradle docker
- org.trellisldp.camel.kafka.elasticsearch.cfg
$ docker run -ti trellisldp/camel-kafka-elasticsearch
-
Start trellis-compose
-
Start elasticsearch-compose
- The Kibana interface can be accessed at
http://localhost:5601
$ curl -v "http://localhost:9200/trellis/_search?q=object.type:http\:\/\/www.w3.org\/ns\/ldp#RDFSource"
$ sudo sysctl -w vm.max_map_count=262144
- route request to ACTIVITY_STREAM_OBJECT_ID, retrieve body as JSON-LD, and index resource property values.