THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Under Discussion Accepted
Discussion thread: here
JIRA: KAFKA-4426
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Tries to close the consumer cleanly within the specified timeout. If the close does not complete within the * timeout, force close the producerconsumer. */ public void close(long timeout, TimeUnit unit); |
...