...

Public Interfaces

We propose to add a static an initialization method to the KafkaStreams class. Method init() uses the topology and the application properties to set sets up the broker-side state for a Kafka Streams application. It needs to be called at least from one Kafka Streams client.

public class KafkaStreams {

	public static void init(final Topology topology,
                            final Properties props);

}

We propose to add a new configuration to Kafka Streams to determine whether the initialization should be done automatically during a rebalance or by the user calling KafkaStreams.initusers calling KafkaStreams#init().

public class StreamsConfig {

	// possible values
	public static final String AUTOMATIC_INITIALIZATION = "automatic";
	public static final String USERMANUAL_INITIALIZATION = "usermanual";

	// configuration
    public static final String APPLICATION_INITIALIZATION = "application.initialization";  // default is AUTOMATIC_INITIALIZATION 
 
}

...