Updated on 2025-08-07 GMT+08:00

Routing to DMS for Kafka

Configure DMS for Kafka as the event target when creating an event stream.

Constraints

Custom certificates are not supported in the event target DMS for Kafka.

Prerequisites

You have enabled DMS for Kafka as the event target.

Procedure

  1. Log in to the EG console.
  2. In the navigation pane, choose Event Streams > Serverless Event Streams.
  3. Click Create Serverless Event Stream, click the icon in the upper left corner, enter the event stream name and description, and click OK.
  4. Configure the event source by referring to Distributed Message Service (DMS) for Kafka.
  5. Configure the event target.

    1. Click Event Target.
    2. Select Distributed Message Service (DMS) for Kafka for Target.
    3. Set event target parameters.
      Figure 1 Distributed Message Service (DMS) for Kafka
      Table 1 Distributed Message Service (DMS) for Kafka parameters

      Parameter

      Description

      Connection

      Select a connection. If no connection is available, create a Kafka connection first. For details, see Connections.

      Topic

      First select a connection, and then select a topic.

      Message Key

      Disable

      Do not use a message key.

      Enable

      Variable: The key is a variable value from CloudEvents-compliant events.

      Constant: The key is a specified constant. All messages will be sent to the same partition.

      Rule

      Transform Type

      EG transforms CloudEvents-compliant events for targets. The following three types are supported:
      • Pass-through: Route the complete structure of native events directly to the target.
      • Variables: Route only parameters extracted from events with JSONPath to the target.
      • Constants: Route only constants in events to the target as a trigger.

      For more information about the transform types, see Event Content Transformation.

      Message Push

      Batch Push

      Specify whether to enable batch push to aggregate multiple events.

      Messages

      Interval (s)

      The maximum number of aggregated records that can be pushed at a time. Default: 100. Range: 1–10,000. This parameter is available only when Batch Push is enabled.

      The interval between batch pushes, in seconds. Default: 1. Range: 0–15. This parameter is available only when Batch Push is enabled.