THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Under DiscussionAdopted (3.3.0)
Discussion thread: here
Vote thread: here
...
Code Block | ||
---|---|---|
| ||
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) } } |
...