Package io.krabka.streams

package io.krabka.streams
Defaults and entry points for Apache Kafka Streams applications.

Example

var settings = Map.<String, Object>of(
    StreamsConfig.APPLICATION_ID_CONFIG, "orders",
    StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
var streams = new KafkaStreams(topology, KrabkaStreamsConfig.withDefaults(settings));
streams.start();