public class ControllerServerRestHandler extends Object implements io.confluent.rest.BeginShutdownControllerHandle, io.confluent.rest.CheckReadyControllerHandle
Constructor and Description |
---|
ControllerServerRestHandler(org.apache.kafka.common.utils.LogContext logContext,
org.apache.kafka.common.utils.Time time,
int nodeId,
Function<String,org.apache.kafka.clients.admin.Admin> adminClientSupplier,
boolean zkMigrationEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
io.confluent.rest.CheckReadyControllerStatus |
generateReadinessStatus() |
io.confluent.rest.BeginShutdownControllerStatus |
generateRollableStatus() |
public io.confluent.rest.BeginShutdownControllerStatus generateRollableStatus()
generateRollableStatus
in interface io.confluent.rest.BeginShutdownControllerHandle
public io.confluent.rest.CheckReadyControllerStatus generateReadinessStatus()
generateReadinessStatus
in interface io.confluent.rest.CheckReadyControllerHandle
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException