org.apache.kafka.common

Interface GenericCoordinator

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

public interface GenericCoordinator
extends java.io.Closeable

Method Summary

Modifier and Type	Method and Description
void	ensureActiveGroup()
void	ensureCoordinatorReady()
void	maybeLeaveGroup()
java.lang.String	memberId()
void	poll(long timeout)
void	requestRejoin()
void	wakeup()

Methods inherited from interface java.io.Closeable

close

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()