Package org.apache.kafka.common
Interface GenericCoordinator
-
- All Superinterfaces:
java.lang.AutoCloseable,java.io.Closeable
public interface GenericCoordinator extends java.io.Closeable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidensureActiveGroup()voidensureCoordinatorReady()voidmaybeLeaveGroup()java.lang.StringmemberId()voidpoll(long timeout)voidrequestRejoin()voidwakeup()
-
-
-
Method Detail
-
ensureCoordinatorReady
void ensureCoordinatorReady()
-
ensureActiveGroup
void ensureActiveGroup()
-
requestRejoin
void requestRejoin()
-
memberId
java.lang.String memberId()
-
wakeup
void wakeup()
-
poll
void poll(long timeout) throws WakeupException
- Throws:
WakeupException
-
maybeLeaveGroup
void maybeLeaveGroup()
-
-