io.confluent.rest

Class InternalRestServer

java.lang.Object

io.confluent.rest.InternalRestServer

public final class InternalRestServer
extends Object

Binds a Rest Server to the provided port, serving the RollHandler API.

Constructor Summary

Constructors

Constructor and Description
InternalRestServer(int port, BeginShutdownBrokerHandle beginShutdownBrokerHandle, KafkaRestorePartitionHandle kafkaRestorePartitionHandle, AuditJobHandle auditJobHandle)

Method Summary

Modifier and Type	Method and Description
void	start() Bind the RestServer to the provided port.
void	stop()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InternalRestServer

public InternalRestServer(int port,
                          BeginShutdownBrokerHandle beginShutdownBrokerHandle,
                          KafkaRestorePartitionHandle kafkaRestorePartitionHandle,
                          AuditJobHandle auditJobHandle)

Method Detail

start

public void start()
           throws Exception

Bind the RestServer to the provided port.

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception