Configuring DMS for Kafka as the Event Source

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 a Kafka event source.
   1. Click Event Source.
   2. Select Distributed Message Service (DMS) for Kafka for Event Provider.
   3. Set event source parameters.
      Figure 1 Kafka event source
      

      Table 1 Kafka parameters

      Parameter	Description
      Instance	Select a Kafka instance.
      Access Mode	Select Ciphertext Access or Plaintext Access.
      Security Protocol	If you select Ciphertext Access for Access Mode, the corresponding security protocol will be displayed.
      Topic	Select a topic.
      Consumer Group	Enter a group name.
      Concurrency	Enter the number of concurrent messages. Range: 1–1000. This parameter is autofilled with the number of partitions for the selected topic. Recommended: retain this default number.
      Consumption Offset	Select a consumption offset. Latest: Consumption starts from the latest message in the queue. Earliest: Consumption starts from the earliest message in the queue.
      SASL Mechanism	This parameter is available when SASL_SSL authentication is enabled for the Kafka instance. Select an SASL authentication mechanism. PLAIN: a simple username and password verification mechanism. SCRAM-SHA-512: uses the hash algorithm to generate credentials for usernames and passwords to verify identities. SCRAM-SHA-512 is more secure than PLAIN.
      SASL Certificate URL	This parameter is available when SASL_SSL authentication is enabled for the Kafka instance. Enter an SASL certificate URL.
      SASL Certificate Key	This parameter is available when SASL_SSL authentication is enabled for the Kafka instance. Enter an SASL certificate key.
      Username	This parameter is available when SASL_SSL authentication is enabled for the Kafka instance. Enter a username.
      Password	This parameter is available when SASL_SSL authentication is enabled for the Kafka instance. Enter a password.

6. Click Save.
7. Configure an event target by referring to Routing to FunctionGraph.
8. After the event source and target are configured, click Save in the upper right.