What is a Kahpp Instance?
A Kahpp Instance or just Instance is a YAML file, essentially a configuration, but we can think of it as the description of the pipeline.
Simple instance
Here a straightforward Kahpp instance that consumes from source-topic
and sinks records on sink-topic
.
kahpp:
group: dev
name: simple-instance
topics:
source: source-topic
sink: sink-topic
streamsConfig:
bootstrapServers:
- kafka:9092
cache-max-size-buffering: 300MB
steps:
- name: produceRecordToSinkTopic
type: dev.vox.platform.kahpp.configuration.topic.ProduceToTopic
config:
topic: sink
Kahpp instance location
Default location for an Instance is kahpp/application.yaml
.
It's possible to override the location using the KAHPP_CONFIG_LOCATION
environment variable.
Configuration
YAML KEY | DESCRIPTION |
---|---|
kahpp.group | Logical name of the group that owns the instance, it can be company or teams or domain etc. |
kahpp.name | Name of the instance |
kahpp.topics.source | Source topic, the entry point of the pipeline |
kahpp.streamsConfig.bootstrapServers | The Kafka bootstrap servers. |
kahpp.streamsConfig.* | All other kahpp.streamsConfig, follow the official Kafka configuration parameter reference |
kahpp.steps | List of the steps, describe the pipeline. |