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, TierMetadataRecoveryHandle tierMetadataRecoveryHandle)
InternalRestServer(Map<?,?> originals, BeginShutdownBrokerHandle beginShutdownBrokerHandle, KafkaRestorePartitionHandle kafkaRestorePartitionHandle, AuditJobHandle auditJobHandle, TierMetadataRecoveryHandle tierMetadataRecoveryHandle)

Method Summary

Modifier and Type	Method and Description
InternalRestServerConfig	getConfigs()
int	getPort()
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,
                          TierMetadataRecoveryHandle tierMetadataRecoveryHandle)

InternalRestServer

public InternalRestServer(Map<?,?> originals,
                          BeginShutdownBrokerHandle beginShutdownBrokerHandle,
                          KafkaRestorePartitionHandle kafkaRestorePartitionHandle,
                          AuditJobHandle auditJobHandle,
                          TierMetadataRecoveryHandle tierMetadataRecoveryHandle)

Method Detail

getConfigs

public InternalRestServerConfig getConfigs()

getPort

public int getPort()

start

public void start()
           throws Exception

Bind the RestServer to the provided port.

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception