Server¶

Server is a ksqlDB API server that deploys ServerVerticles (on the Vertx actor system).

Creating Instance¶

Server takes the following to be created:

• Vertx (Vert.x)
• KsqlRestConfig
• Endpoints
• KsqlSecurityExtension
• AuthenticationPlugin
• ServerState
• PullQueryExecutorMetrics

Server is created when:

• KsqlRestApplication is requested to startAsync

Starting API Server¶

void start()

start...FIXME

start takes ksql.verticle.instances configuration property (from the KsqlRestConfig).

start prints out the following DEBUG message to the logs:

Deploying [instances] instances of server verticle

start creates and deploys a ServerVerticle for every listener URI and ksql.verticle.instances configured.

start is used when:

• KsqlRestApplication is requested to startAsync
• Server is requested to restart

Restarting API Server¶

void restart()

restart prints out the following INFO message to the logs:

Restarting server

In the end, restart stops and immediately starts the API server.

restart is used when:

• Server is requested to configureTlsCertReload

Logging¶

Enable ALL logging level for io.confluent.ksql.api.server.Server logger to see what happens inside.

Add the following line to log4j.properties:

log4j.logger.io.confluent.ksql.api.server.Server=ALL

Refer to Logging.