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 void
ensureActiveGroup()
void
ensureCoordinatorReady()
void
maybeLeaveGroup()
java.lang.String
memberId()
void
poll(long timeout)
void
requestRejoin()
void
wakeup()
-
-
-
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()
-
-