Skip to content

Commit d64f703

Browse files
authored
Merge pull request #9 from shreyb/master
Add documentation for store directory
2 parents 3f41ab9 + 5a8eb97 commit d64f703

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

de_monitoring/store/README.md

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
# Kafka "store" explanation and configuration
2+
3+
In Fermilab's monitoring ecosystem, [Landscape](https://landscape.fnal.gov), we use a [Kafka](https://kafka.apache.org/) cluster to manage input streams of data. The convention we currently use within our Kafka cluster for each data path consists of three steps:
4+
5+
1. Establishment of an input topic to accept raw data.
6+
2. Modification of the raw data by reading from the input topic, making changes, and writing to a digest topic.
7+
3. Sending the digest data to its final destination (such as an Elasticsearch or Graphite instance).
8+
9+
The second two steps are accomplished via [Logstash](https://www.elastic.co/downloads/logstash) instances run in [Docker](https://www.docker.com/) containers. Included in this directory is a simple sample configuration that can be used to run a Logstash instance. Simply create the indicated Kafka topics (or create your own names and edit the configuration accordingly), and pass in the logstash configuration file to the Logstash executable via the `-f` flag.
10+
11+
Included in this directory is also a mapping template to use with logstash to send data to Elasticsearch. NOTE: This mapping template needs to be updated to match the current schema.

de_monitoring/store/mapping-template.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
{
2-
"index_patterns": "hepcloud-classads-slots-*",
2+
"index_patterns": "hepcloud-de-*",
33
"settings": {
44
"index": {
55
"refresh_interval": "60s",

0 commit comments

Comments
 (0)