Azkarra Worker
Downloading Azkarra Worker
AZKARRA_VERSION=0.7.4
wget https://github.com/streamthoughts/azkarra-streams/releases/download/v$AZKARRA_VERSION/azkarra-worker-$AZKARRA_VERSION.tar.gz -P .
tar -xzvf azkarra-worker-$AZKARRA_VERSION.tar.gz
cd azkarra-worker-$AZKARRA_VERSION
The installation contains the following structure :
├── bin
│ ├── azkarra-streams-start.sh
│ └── azkarra-streams-stop.sh
├── etc
│ ├── azkarra.conf
│ └── log4j2.xml
├── LICENSE
├── README.md
└── share
└── java
└── azkarra-worker
Running Worker
You can start a worker process with the following command :
./bin/azkarra-streams-start.sh [-daemon]
Configuring Worker
Azkarra uses the Config library developed by Lightbend to ease the configuration of your application from an external file.
You can use the -Dconfig.file
system property to specify the config source to load.
Example:
STREAMS_JVM_OPTS=-Dconfig.file=./config/azkarra.conf ./bin/azkarra-streams-start.sh
Configs can also be passed passed to the command should be in the form of [--property value]*
.
These parameters are then passed to the Azkarra main method.
Example:
STREAMS_JVM_OPTS=-Dconfig.file=./config/azkarra.conf ./bin/azkarra-streams-start.sh \
--azkarra.component.paths /usr/share/azkarra-components
--azkarra.context.streams.bootstrap.servers localhost:9092
External Components
To make your external components (e.g, TopologyProvider
) available to the worker, installed them into one or many local directories.
Use the azkarra.component.paths
property to configure the list of locations (separated by a comma)
from which the components will be scanned.
Each configured directories may contain:
- an uber JAR containing all of the classes and third-party dependencies for the component (e.g., topology).
- a directory containing all JARs for the component.
Using Docker
An official Docker image is available on Docker Hub.
Example :
docker run --net host streamthoughts/azkarra-streams-worker \
--mount type=bind,src=/tmp/azkarra/application.conf,dst=/etc/azkarra/azkarra.conf \
--mount type=bind,src=/tmp/components,dst=/usr/share/azkarra-components/ \
streamthoughts/azkarra-streams-worker