Skip to content

InsertsStreamEndpoint

InsertsStreamEndpoint is used to create an InsertsStreamSubscriber for KsqlServerEndpoints.

Creating Instance

InsertsStreamEndpoint takes the following to be created:

InsertsStreamEndpoint is created when:

KsqlEngine

InsertsStreamEndpoint is given a KsqlEngine when created.

The KsqlEngine is used when creating an InsertsStreamSubscriber (to access the MetaStore to get a DataSource).

Creating InsertsStreamSubscriber

InsertsStreamSubscriber createInsertsSubscriber(
  String caseInsensitiveTarget,
  JsonObject properties,
  Subscriber<InsertResult> acksSubscriber,
  Context context,
  WorkerExecutor workerExecutor,
  ServiceContext serviceContext)

createInsertsSubscriber...FIXME

createInsertsSubscriber is used when: