GenericCoordinator (kafka 2.6.1.100-eep-810 API)

All Superinterfaces:: AutoCloseable, Closeable

public interface GenericCoordinator
extends Closeable

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`ensureActiveGroup()`
`void`	`ensureCoordinatorReady()`
`void`	`maybeLeaveGroup()`
`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
```
String memberId()
```

wakeup
```
void wakeup()
```

poll

void poll(long timeout)
   throws WakeupException

Throws:: WakeupException

maybeLeaveGroup
```
void maybeLeaveGroup()
```