Page History

public class KafkaStreams {

	/**
	 * Initializes broker-side state.
     * 
     * If some but not all of the internal topics are absent it throws an exception.
     */
	public void init();

    /**
     * Initializes broker-side state.
     *
     * This methods takes parameters that specify which internal topics to setup if some
     * but not all of them are absent.
     */
	public void init(final InitParameters initParameters);

	public class InitParameters {
        
        public static InitParameters initParameters();                        // specifies to disable all setup of internal topics 

 		public InitParameters enableSetupRepartitionTopicsIfIncomplete();     // specifies to setup repartition topics if some are missing
 		public InitParameters disableSetupRepartitionTopicsIfIncomplete();    // specifies to throw if some but not all repartition topics are missing
 		public boolean setupRepartitionTopicsIfIncompleteEnabled();           // getter
 		public InitParameters enableSetupChangelogTopicsIfIncomplete();       // specifies to setup changelog topics if some are missing
 		public InitParameters disableSetupChangelogTopicsIfIncomplete();      // specifies to throw if some but not all changelog topics are missing
 		public boolean setupChangelogTopicsIfIncompleteEnabled();             // getter
 		public InitParameters enableSetupInternalTopicsIfIncomplete();        // specifies to setup repartition and changelog topics if some are missing
 		public InitParameters disableSetupInternalTopicsIfIncomplete();       // specifies to throw if some but not all repartition or changelog topics are missing
 		public boolean setupInternalTopicsIfIncompleteEnabled();              // getter
	}
}