Show TOC

AsapSink PropertiesLocate this document in the navigation structure

The AsapSink component takes records from the source and delivers them to Event Stream Processor.

Ensure that every input adapter configuration includes exactly one AsapSink component.

ClassName=com.sybase.esp.adapter.asap.AsapSink

Property Description

ProjectUri

(Dependent required) Connect to the Server running in cluster mode. For example, esp[s]://localost:19011/ws1/p1.

User (Required) The initial connection between AsapSink and Event Stream Processor requires authentication. Enter a valid user name known to Event Stream Processor.
Passwd (Required) The initial connection between AsapSink and Event Stream Processor requires authentication. Enter a valid password for the user name. If the UseSSL property is set to true, the user and password information is passed to the Event Stream Processor before the SSL connection is set up. These details are passed in plain text.
Stream++ (Required) The name of the stream to which the data is delivered.
IsEncrypted (Optional) If present and set to true, AsapSink attempts to use an SSL connection to Event Stream Processor.

UseServerRSA

(Optional) If true, server RSA authentication is used to connect to the Server. If you specify this property, also provide the KeyStore and KeyStorePassword properties.

KeyStore

(Optional) Used for server RSA authentication. Specifies the location of the keystore (.jks file). Set this property if you specify UseServerRSA.

KeyStorePassword

(Optional) Specify the keystore password. This is used for server RSA authentication. Set this property if you specify UseServerRSA.

UseKerberos

(Optional) If true, Kerberos authentication is used to connect to the Server. If you specify this property, also provide the KerberosKDC, KerberosRealm, KerberosService, and KerberosTicketCache properties.

KerberosKDC

(Optional) Used for Kerberos authentication. Specifies the host name of Kerberos key distribution center. Set this property if you specify UseKerberos.

KerberosRealm

(Optional) Used for Kerberos authentication. Specifies the Kerberos realm setting. Set this property if you specify UseKerberos.

KerberosService

(Optional) Used for Kerberos authentication. Specifies the Kerberos principal name that identifies an Event Stream Processor cluster. Set this property if you specify UseKerberos.

KerberosTicketCache

(Optional) Used for Kerberos authentication. Specifies the location of the Kerberos ticket cache. Set this property if you specify UseKerberos.

UseUserPassword

(Optional) If set to true, User and Password authentication is used to connect to the Server. If you specify this, provide values for User and Password.

SHINE (Optional) Used for update and upsert operations. If a field is set to shine through, then an update to an existing record does not affect the value of that field.
PublishMethod (Optional) Determines how the data is published to the Event Stream Processor: RECORD, COLLECTION, ENVELOPE, TRANSACTION.

With the RECORD method, records are published individually. The other three types are bulk publisher methods. The ENVELOPE and TRANSACTION methods behave similarly. They create blocks per streams and then publish those blocks once the required number of records accumulates.

With TRANSACTION, if any single record in the block fails to publish, the entire block fails to publish. However, with ENVELOPE, the remaining records have other attempts at being published.

The COLLECTION type is similar to ENVELOPE but it creates blocks regardless of streams and publishes all records in the block simultaneously.

SyncBaseStreams

(Optional) Asks Event Stream Processor for SYNC_BASE_STREAMS. When set to true, the publisher.commit() method is called after each batch is published to the Event Stream Processor.

Default value is false.

DiscardFile (Optional) Name of the file for discarded SDOs.
TruncateDiscardFile (Optional) If set to true, the file is truncated.
EspOpsColumn (Optional) If set, the value of the ESP_OPS attribute in the incoming records is written to the corresponding column and the record is treated as an UPSERT regardless of the ESP_OPS value.
MaxRecordsPerBlock

(Optional) An integer value specifying the maximum number of records to send as a transactional unit to Event Stream Processor. If no value is specified, the default is 0 and all records in the collection get published in a single transaction block to Event Stream Processor.