THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 = null; private boolean leaveGroup = false; public CloseOptions timeoutMstimeout(IntegerDuration timeoutMstimeout) public CloseOptions leaveGroup(boolean leaveGroup) } } |
...