Index

A C G H I K L M P R S V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

awaitStarted() - Method in class io.confluent.http.server.KafkaHttpServerImpl

awaitStarted(Duration) - Method in class io.confluent.http.server.KafkaHttpServerImpl

awaitStopped() - Method in class io.confluent.http.server.KafkaHttpServerImpl

awaitStopped(Duration) - Method in class io.confluent.http.server.KafkaHttpServerImpl

C

configDef() - Static method in class io.confluent.http.server.KafkaHttpServerConfig

configure(Map<String, ?>) - Method in class io.confluent.http.server.KafkaHttpServerImpl

G

getApplicationServer() - Method in class io.confluent.http.server.KafkaHttpServerImpl

getError() - Method in class io.confluent.http.server.KafkaHttpServerImpl

getPrimaryPort() - Method in class io.confluent.http.server.KafkaHttpServerImpl

H

hasListenersConfig() - Method in class io.confluent.http.server.KafkaHttpServerConfig

HTTP_SERVER_PREFIX - Static variable in class io.confluent.http.server.KafkaHttpServerConfig

I

io.confluent.http.server - package io.confluent.http.server

isFailed() - Method in class io.confluent.http.server.KafkaHttpServerImpl

isNew() - Method in class io.confluent.http.server.KafkaHttpServerImpl

isRunning() - Method in class io.confluent.http.server.KafkaHttpServerImpl

isStarting() - Method in class io.confluent.http.server.KafkaHttpServerImpl

isStopping() - Method in class io.confluent.http.server.KafkaHttpServerImpl

isTerminated() - Method in class io.confluent.http.server.KafkaHttpServerImpl

K

KafkaHttpApplicationLoadingException - Exception Class in io.confluent.http.server

Exception thrown when the Kafka HTTP server fails to load an application.

KafkaHttpApplicationProvider - Interface in io.confluent.http.server

A provider for Application.

KafkaHttpServerConfig - Class in io.confluent.http.server

KafkaHttpServerConfig(Map<String, ?>) - Constructor for class io.confluent.http.server.KafkaHttpServerConfig

KafkaHttpServerConfig(Map<String, ?>, boolean) - Constructor for class io.confluent.http.server.KafkaHttpServerConfig

KafkaHttpServerImpl - Class in io.confluent.http.server

An HTTP Server that runs applications loaded from the classpath on the Kafka broker.

KafkaHttpServerImpl(List<Application<?>>, KafkaHttpServerConfig) - Constructor for class io.confluent.http.server.KafkaHttpServerImpl

KafkaHttpServerProviderImpl - Class in io.confluent.http.server

A KafkaHttpServerProvider that installs KafkaHttpServerImpl as implementation of KafkaHttpServer.

KafkaHttpServerProviderImpl() - Constructor for class io.confluent.http.server.KafkaHttpServerProviderImpl

L

LISTENERS_DEFAULT - Static variable in class io.confluent.http.server.KafkaHttpServerConfig

M

METADATA_SERVER_PREFIX - Static variable in class io.confluent.http.server.KafkaHttpServerConfig

P

PER_LISTENER_CONFIG_PREFIX - Static variable in class io.confluent.http.server.KafkaHttpServerConfig

PORT_DEFAULT - Static variable in class io.confluent.http.server.KafkaHttpServerConfig

provide(Map<String, Object>, KafkaHttpServerInjector) - Method in class io.confluent.http.server.KafkaHttpServerProviderImpl

provideApplications(Map<String, Object>, KafkaHttpServerInjector) - Method in interface io.confluent.http.server.KafkaHttpApplicationProvider

Returns a collection of Application instances, possibly empty if the application is disabled.

R

reconfigurableConfigs() - Method in class io.confluent.http.server.KafkaHttpServerImpl

reconfigure(Map<String, ?>) - Method in class io.confluent.http.server.KafkaHttpServerImpl

S

scoped(Map<String, ?>) - Static method in class io.confluent.http.server.KafkaHttpServerConfig

start() - Method in class io.confluent.http.server.KafkaHttpServerImpl

stop() - Method in class io.confluent.http.server.KafkaHttpServerImpl

V

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.http.server.KafkaHttpServerImpl

A C G H I K L M P R S V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form