Class KafkaHttpServerImpl

java.lang.Object
io.confluent.http.server.KafkaHttpServerImpl
All Implemented Interfaces:
io.confluent.kafka.http.server.KafkaHttpServer, org.apache.kafka.common.Configurable, org.apache.kafka.common.Reconfigurable
public final class KafkaHttpServerImpl extends Object implements io.confluent.kafka.http.server.KafkaHttpServer, org.apache.kafka.common.Reconfigurable
An HTTP Server that runs applications loaded from the classpath on the Kafka broker.

  • Constructor Details

    • KafkaHttpServerImpl

      public KafkaHttpServerImpl(List<io.confluent.rest.Application<?>> applications, KafkaHttpServerConfig configuration)

  • Method Details

    • getApplicationServer

      public io.confluent.rest.ApplicationServer<KafkaHttpServerConfig> getApplicationServer()

    • isNew

      public boolean isNew()
      Specified by:
      isNew in interface io.confluent.kafka.http.server.KafkaHttpServer

    • isStarting

      public boolean isStarting()
      Specified by:
      isStarting in interface io.confluent.kafka.http.server.KafkaHttpServer

    • isRunning

      public boolean isRunning()
      Specified by:
      isRunning in interface io.confluent.kafka.http.server.KafkaHttpServer

    • isStopping

      public boolean isStopping()
      Specified by:
      isStopping in interface io.confluent.kafka.http.server.KafkaHttpServer

    • isTerminated

      public boolean isTerminated()
      Specified by:
      isTerminated in interface io.confluent.kafka.http.server.KafkaHttpServer

    • isFailed

      public boolean isFailed()
      Specified by:
      isFailed in interface io.confluent.kafka.http.server.KafkaHttpServer

    • getError

      public Optional<Throwable> getError()
      Specified by:
      getError in interface io.confluent.kafka.http.server.KafkaHttpServer

    • start

      public void start()
      Specified by:
      start in interface io.confluent.kafka.http.server.KafkaHttpServer

    • stop

      public void stop()
      Specified by:
      stop in interface io.confluent.kafka.http.server.KafkaHttpServer

    • awaitStarted

      public void awaitStarted() throws InterruptedException
      Specified by:
      awaitStarted in interface io.confluent.kafka.http.server.KafkaHttpServer
      Throws:
      InterruptedException

    • awaitStarted

      public boolean awaitStarted(Duration timeout) throws InterruptedException
      Specified by:
      awaitStarted in interface io.confluent.kafka.http.server.KafkaHttpServer
      Throws:
      InterruptedException

    • awaitStopped

      public void awaitStopped() throws InterruptedException
      Specified by:
      awaitStopped in interface io.confluent.kafka.http.server.KafkaHttpServer
      Throws:
      InterruptedException

    • awaitStopped

      public boolean awaitStopped(Duration timeout) throws InterruptedException
      Specified by:
      awaitStopped in interface io.confluent.kafka.http.server.KafkaHttpServer
      Throws:
      InterruptedException

    • reconfigurableConfigs

      public Set<String> reconfigurableConfigs()
      Specified by:
      reconfigurableConfigs in interface org.apache.kafka.common.Reconfigurable

    • validateReconfiguration

      public void validateReconfiguration(Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
      Specified by:
      validateReconfiguration in interface org.apache.kafka.common.Reconfigurable
      Throws:
      org.apache.kafka.common.config.ConfigException

    • reconfigure

      public void reconfigure(Map<String,?> configs)
      Specified by:
      reconfigure in interface org.apache.kafka.common.Reconfigurable

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • getPrimaryPort

      public int getPrimaryPort()