Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Table of Contents

Status

Current state: Under DiscussionAdopted (3.3.0)

Discussion thread: here

Vote Discussion thread: here

JIRA: here

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

Code Block
languagejava
package org.apache.kafka.streams;

public class KafkaStreams implements AutoCloseable {
    public void close()  // Already exist 
    private boolean close(final long timeoutMs)
	  // Already exist
    public synchronized boolean close(final Duration timeout) throws IllegalArgumentException  // Already exist
    	public synchronized boolean close(CloseOptions options) throws IllegalArgumentException  // *This one will be added

 	public static class CloseOptions {
		private IntegerDuration timeoutMstimeout = nullDuration.ofMillis(Long.MAX_VALUE);
    	private boolean leaveGroup = false;

 	    public CloseOptions timeoutMstimeout(IntegerDuration timeoutMstimeout) 
	    public CloseOptions leaveGroup(boolean leaveGroup)
	}
}

...