Skip to main content

Create Kafka Writer Application

Kafka Writer (the new KafkaWriter target described in this guide) accepts the same input stream types supported by its formatters: WAEvent (from OLTP, DWH, file, message bus, and application sources), AvroEvent, JSONNodeEvent, ParquetEvent, and TypedEvent.

Prerequisites

Before creating a Kafka Writer application, ensure the following are in place:

  1. Running Striim 5.4.2 or later --- KafkaWriter as described in this guide is available starting in this release.

  2. A Kafka Connection Profile has been created and tested (see Setting up Connection to Kafka).

  3. If using a Schema Registry, a Schema Registry Connection Profile has been created (see Connecting to Schema Registry).

  4. If using the Striim Vault for certificates, the vault entries are populated (see Using the Striim Vault).

  5. The target Kafka cluster is accessible from the Striim node.

  6. Required ACLs are granted to the Striim service account.

  7. Your source produces one of the supported input stream types listed above.