{"repo":"bakdata/streams-bootstrap","free":true,"listed":false,"github":"https://github.com/bakdata/streams-bootstrap","clone":"git clone https://github.com/bakdata/streams-bootstrap.git","description":"Utility functions and base classes for Kafka Streams applications","language":"Java","stars":39,"topics":["helm","kafka","kafka-streams","kubernetes","stream-processing"],"license":"MIT","category":"data-pipelines","readme_excerpt":"streams-bootstrap streams-bootstrap provides base classes and utility functions for Kafka Streams applications. It provides a common way to - configure Kafka Streams applications - deploy streaming applications on Kubernetes via Helm charts - reprocess data Visit our blogpost and demo for an overview and a demo application. The common configuration and deployments on Kubernetes are supported by the Streams Explorer, which makes it possible to explore and monitor data pipelines in Apache Kafka. Getting Started You can add streams-bootstrap via Maven Central. Gradle Maven For other build tools or versions, refer to the latest version in MvnRepository. Usage Kafka Streams Create a subclass of KafkaStreamsApplication and implement the abstract methods buildTopology() and getUniqueAppId() . You can define the topology of your application in buildTopology() . The following configuration options are available: - --bootstrap-servers , --bootstrap-server : List of Kafka bootstrap servers (comma-separated) ( required ) - --schema-registry-url : The URL of the Schema Registry - --kafka-config : Kafka Streams configuration ( [, ...] ) - --input-topics : List of input topics (comma-separated) - --input-pattern : Pattern of input topics - --output-topic : The output topic - --error-topic : A topic to write errors to - --labeled-input-topics : Additional labeled input topics if you need to specify multiple topics with different message types ( [, ...] ) - --labeled-input-patterns : Addition","default_branch":null,"files":null,"tree":[],"storefront":"/r/bakdata","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/bakdata/streams-bootstrap/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}