JarCasting
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
compile group: 'com.bakdata.kafka', name: 'streams-bootstrap', version: '1.7.0'
Maven
<dependency>
<groupId>com.bakdata.kafka</groupId>
<artifactId>streams-bootstrap</artifactId>
<version>1.7.0</version>
</dependency>
For other build tools or versions, refer to the latest version in MvnRepository.
Usage
Create a subclass of KafkaStreamsApplication and implement the abstract methods buildTopology() and getUniqueAppId(). You can define the topology of your application in buildTopology().
import java.util.Properties;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.kstream.KStream;
public class StreamsBootstrapApplication extends KafkaStreamsApplication {
public static void main(final String[] args) {
startApplication(new StreamsBootstrapApplication(), args);
}
@Override
public void buildTopology(final StreamsBuilder builder) {
final KStream<String, String> input =
builder.<String, String>stream(this.getInputTopics());
// your topology
input.to(this.getOutputTopic());
}
@Override
public String getUniqueAppId() {
return "streams-bootstrap-app";
}
// Optionally you can override the default streams bootstrap Kafka properties
@Override
protected Properties createKafkaProperties() {
final Properties kafkaProperties = super.createKafkaProperties();
return kafkaProperties;
}
}
The following configuration options are available (can be passed per arguments or environment variables):
-
brokers: List of Kafka brokers (comma-separated) (required) -
schema-registry-url: The URL of the schema registry (required) -
input-topics: List of input topics (comma-separated) -
output-topic: The output topic -
error-topic: A topic to write errors to (default:error_topic) -
streams-config: Additional Kafka properties (<String=String>[,<String=String>...]) -
extra-input-topics: Additional input topics (<String=String>[,<String=String>...]) -
extra-output-topics: Additional output topics (String=String>[,<String=String>...]) -
clean-up: Whether the state store and the Kafka offsets for the consumer group should be cleared -
delete-output: Whether the output topic should be deleted during the cleanup
Helm Charts
For the configuration and deployment to Kubernetes, you can use the Helm Charts. To configure your streams-bootstrap app, you can use the values.yaml as a starting point.
Development
If you want to contribute to this project, you can simply clone the repository and build it via Gradle. All dependencies should be included in the Gradle files, there are no external prerequisites.
> git clone [email protected]:bakdata/streams-bootstrap.git
> cd streams-bootstrap && ./gradlew build
Please note, that we have code styles for Java. They are basically the Google style guide, with some small modifications.
Contributing
We are happy if you want to contribute to this project. If you find any bugs or have suggestions for improvements, please open an issue. We are also happy to accept your PRs. Just open an issue beforehand and let us know what you want to do and why.
License
This project is licensed under the MIT license. Have a look at the LICENSE for more details.
