Help Center> EventGrid> User Guide> Event Streams> Event Source> Configuring DMS for Kafka as the Event Source
Updated on 2023-12-26 GMT+08:00
View PDF

Configuring DMS for Kafka as the Event Source

Configure a DMS for Kafka instance as the source of an event stream.

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.
Parent topic: Event Source