Kafka Alfresco Module

Alfresco repository customization for generating messages of Alfresco actions and save into Apache Kafka server. Then Kafka connects with Logstash and Elasticsearch for indexing the message information.

This project use:

• Alfresco 5.2 with SDK 3.0.0
• Kafka 2.12
• Logstash 5.5
• Elasticsearch 5.5
• Kibana 5.5

Build and Run Alfresco

Run embedded Tomcat + H2 DB with mvn clean install -DskipTests=true alfresco:run or ./run.sh

Run Kafka Server & Zookeeper

• Start Zookeeper: ./bin/zookeeper-server-start.sh config/zookeeper.properties
• Start Kafka: ./bin/kafka-server-start.sh config/server.properties

Kafka Consumer

Run ./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TOPIC_TYPE and view all generated messages in real time.

Run Elasticsearch Stack

• Install Kafka Input Plugin: ./logstash-5.5.0/bin/logstash-plugin install logstash-input-kafka
• Start Elasticsearch: ./elasticsearch-5.5.0/bin/elasticsearch
• Start Kibana: ./kibana-5.5.0-darwin-x86_64/bin/kibana
• Start Logstash: ./logstash-5.5.0/bin/logstash -f logstash-5.5.0/logstash.conf --config.reload.automatic

Alfresco Configuration

Configure Kafka host and port server from alfresco-global.properties file.

kafka.server.host=localhost kafka.server.port=9092