ServiceContext¶

ServiceContext is an abstraction of service contexts.

Contract (Subset)¶

getAdminClient¶

Admin getAdminClient()

Admin (Apache Kafka)

Used when:

• KsqlEngine is requested to createStreamPullQuery
• KsqlAuthorizationValidatorFactory is requested to isTopicAccessValidatorEnabled
• KafkaClusterUtil is requested to getKafkaClusterId
• SandboxedServiceContext is created
• ListTopicsExecutor is requested to execute (a LIST TOPICS statement)

getConsumerGroupClient¶

KafkaConsumerGroupClient getConsumerGroupClient()

Used when:

• QueryCleanupTask is requested to run
• ScalablePushRegistry is requested to deleteConsumerGroup
• SandboxedServiceContext is created
• ListSourceExecutor is requested to queryOffsetSummaries

getKsqlClient¶

SimpleKsqlClient getKsqlClient()

Used when:

• HARouting is requested to forwardTo
• PushRouting is requested to forwardTo
• SendHeartbeatService is requested to runOneIteration
• SendLagService is requested to runOneIteration
• ListQueriesExecutor is requested to execute (a LIST QUERIES statement)
• ListSourceExecutor is requested to sourceDescriptionList
• TerminateQueryExecutor is requested to execute (a TERMINATE QUERY statement)

Implementations¶

• DefaultServiceContext
• LazyServiceContext
• SandboxedServiceContext