Routing to 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.
3. Click Create Event Stream.
4. Enter an event stream name and description, and click OK.
5. Configure the event source by referring to Configuring DMS for Kafka as the Event Source.
6. 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 one with DMS for Kafka.
      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.