QueryEndpoint¶

Creating Instance¶

QueryEndpoint takes the following to be created:

• KsqlEngine
• KsqlConfig
• PullQueryExecutorMetrics
• QueryExecutor

QueryEndpoint is created when:

• KsqlServerEndpoints is requested to createQueryPublisher