Contact Free trial Login

Kafka Design Center Configuration - Mule 4

Design Center enables you to create apps visually. To use Design Center, work with your Anypoint Platform administrator to ensure that you have a Design environment. For more information, see the Flow Designer Tour.

To create an app in Design Center:

  • Configure the input source (trigger) for your app.

  • Add the connector as a component to process the input for the app.

For information on field values, see the Kafka Connector Reference.

Configure the Trigger

  1. In Design Center, click Create.

  2. Click Create new application.

  3. Specify a value for Project name.

  4. Click Go straight to canvas to exit from Let’s get started.

  5. Click the name of the trigger card.

  6. If you are using the Kafka connector as an input source trigger, search for the connector; otherwise, search for HTTP or Scheduler.

  7. Complete the fields with the values you want to configure for your trigger.

Design Center automatically saves changes you make in a session.

The Kafka connector provides the Message Consumer operation as an input source.

To configure the Message Consumer operation, set the field values:

Name Description

Topic

Name of the topic to consume messages from.

Connection

Partition Offsets

List of offsets to configure. For each element in the list, specify a partition index and offset.

Primary Node Only

Whether this source should execute only on the primary node in a cluster.

To configure a consumer (trigger) for all configurations, set:

  • Consumer Partitions - The number of partitions to use for the consumer.

  • Group Id - A unique string that identifies the consumer group this consumer belongs to.

Kafka Basic Consumer Connection

Name Description

Bootstap Servers

Comma-separated host-port pairs used for establishing the initial connection to the Kafka cluster. This is the same as the bootstrap.servers value you must provide to Kafka clients (producer or consumer).

Additional Properties

Additional properties as key-value pairs that you need for your connection. Here you can put whatever property Kafka supports.

kafka basic dc config

Kafka SSL Consumer Connection

Uses all the parameters from Kafka Basic Consumer Connection.

Name Description

Key Store Type

The file format of the key store file. This is optional and the default value is JKS.

Key Store Password

The store password for the key store file. This is optional and only needed if Key Store Location is configured.

Key Store Location

The location of the key store file. This is optional and can be used for two-way authentication for the connector.

Trust Store Type

The file format of the trust store file.

Trust Store Password

The password for the trust store file.

Trust Store Location

The location of the trust store file.

kafka ssl dc config

Kafka Kerberos Consumer Connection

Uses all the parameters from Kafka Basic Consumer Connection.

Name Description

Principal

Kerberos principal.

Keytab

Path to the keytab file associated with principal.

Service Name

The Kerberos principal name that the Kafka broker runs as.

Additional JAAS Properties

Additional properties as key-value pairs that you need to set in sasl.jaas.config and that you usually include in JAAS configuration file.

kafka kerberos dc config

Kafka Kerberos SSL Consumer Connection

Uses all the parameters from these configurations:

kafka kerberos ssl dc config

Add a Component

  1. Click + next to the trigger card.

  2. In Select a component, search for the connector name.

  3. Select the Kafka connector as the component.

    Configure these fields:

  4. Consumer trigger:

    • Topic - Name of Kafka topic to consume messages from.

    • Partition offsets (Optional) - List of offsets for partitions. For each element in the list, specify a partition index and offset.

      kafka consumer dc config
  5. Producer operation:

    • Topic - Topic for where to send a message.

    • Key - Key of the message to send.

    • Message - Message to send.

      kafka producer dc config

Next

Now that you have completed configuring Design Center, see the Kafka Connector topic for more information.

See Also

We use cookies to make interactions with our websites and services easy and meaningful, to better understand how they are used and to tailor advertising. You can read more and make your cookie choices here. By continuing to use this site you are giving us your consent to do this.