Energy State Data Analysis (ESDA)

ESDA is a component-oriented reference and test application for use in performance benchmarks and tests. This community case study emulates a message-based system for analyzing energy state data.

Getting Started

We provide images of the components via Docker Hub. They can be found here:

• https://hub.docker.com/r/kitsdq/esda-analysis
• https://hub.docker.com/r/kitsdq/esda-aggregate
• https://hub.docker.com/r/kitsdq/esda-importer

To deploy the system locally, run:

docker-compose -f docker-compose_kafka.yml up

# Wait until the containers do not output much log data anymore (startup is over).
# In another shell:
docker-compose -f docker-compose_clients.yml up

# Test
docker run --rm -it --network esda_esdanet alpine /bin/sh

Inside the container, run:

apk add curl

curl "importer:8080/add/abc/30"
curl "importer:8080/add/abc/30"
curl "importer:8080/add/abc/30"

Building Yourself

If you want to build the containers yourself, run:

# Git
git clone git@github.com:kit-sdq/esda.git
cd .\esda

# Build
mvn clean package

# Execute
docker-compose -f docker-compose_kafka.yml up

# Wait until the containers do not output much log data anymore (startup is over).
# In another shell:
docker-compose -f docker-compose_clients_build.yml up --build

# Test
docker run --rm -it --network esda_esdanet alpine /bin/sh

Inside the container, run:

apk add curl

curl "importer:8080/add/abc/30"
curl "importer:8080/add/abc/30"
curl "importer:8080/add/abc/30"

Reference Documentation

For further reference, please consider the following sections:

• Kafka Docker
• Official Apache Maven documentation
• Spring for Apache Kafka
• Apache Kafka Streams Support
• Apache Kafka Streams Binding Capabilities of Spring Cloud Stream