Skip to content

Instantly share code, notes, and snippets.

@simplesteph
Created October 22, 2017 07:56
private void start() {
Properties config = getKafkaStreamsConfig();
KafkaStreams streams = createTopology(config);
streams.cleanUp();
streams.start();
Runtime.getRuntime().addShutdownHook(new Thread(streams::close));
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment