Skip to content


InsertsStreamEndpoint is used to create an InsertsStreamSubscriber for KsqlServerEndpoints.

Creating Instance

InsertsStreamEndpoint takes the following to be created:

InsertsStreamEndpoint is created when:


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 is used when: