Skip to content

KsqlServerEndpoints

Creating Instance

KsqlServerEndpoints takes the following to be created:

  • KsqlEngine
  • KsqlConfig
  • KsqlSecurityContextProvider
  • KsqlResource
  • StreamedQueryResource
  • ServerInfoResource
  • HeartbeatResource
  • ClusterStatusResource
  • StatusResource
  • LagReportingResource
  • HealthCheckResource
  • ServerMetadataResource
  • WSQueryEndpoint
  • PullQueryExecutorMetrics
  • QueryExecutor

KsqlServerEndpoints is created when:

Creating QueryPublisher

CompletableFuture<QueryPublisher> createQueryPublisher(
  String sql,
  Map<String, Object> properties,
  Map<String, Object> sessionVariables,
  Map<String, Object> requestProperties,
  Context context,
  WorkerExecutor workerExecutor,
  ApiSecurityContext apiSecurityContext,
  MetricsCallbackHolder metricsCallbackHolder,
  Optional<Boolean> isInternalRequest)

createQueryPublisher...FIXME

createQueryPublisher is part of the Endpoints abstraction.

Executing KsqlRequest

CompletableFuture<EndpointResponse> executeKsqlRequest(
  KsqlRequest request,
  WorkerExecutor workerExecutor,
  ApiSecurityContext apiSecurityContext)

executeKsqlRequest...FIXME

executeKsqlRequest is part of the Endpoints abstraction.

Back to top