Configuring Produce Service for Confluent Kafka
The Produce service delivers a message to a specified Kafka topic. A Produce Service creates a message object from the input signature properties, which becomes the input document. You specify input signature properties when you configure the Produce Service. In the input signature, if a valid partition number is specified, then that partition will be used when sending the message. If no partition is specified but a key is specified, then a partition will be chosen using a hash of the key. If neither key nor partition is specified, then a partition will be assigned in a round-robin fashion. You configure Adapter for Apache Kafka services using Designer.
To configure a Produce service
1. In Designer, right-click the package in which the service should be contained and select New > Adapter Service .
2. Select the parent namespace, type a name for the adapter service, and click Next.
3. Select webMethods Adapter for Apache Kafka as the adapter type and click Next.
4. Select the appropriate Adapter Connection Name of type Confluent Kafka Producer Connection and click Next.
5. From the list of available templates, select the Produce service template and click Finish
The adapter service editor for the adapter service appears. You can select the Adapter Settings tab at any time to confirm adapter service properties such as the Adapter Name, Adapter Connection Name, and Adapter Service Template, as necessary.
6. Select Publish with Schema tab to configure the following fields:
Field | Description |
Topic | Specifies the topic to which message is published. Note:
The topic to which the message is published must be unique across the schema. |
Partition(optional) | Specified partition in which the message is stored. |
Key Schema | Specifies the avro based schema files. |
Value Schema | Specifies the avro based schema files. |
Note:
If the key serializer class or value serializer class is io.confluent.kafka.serializers.KafkaAvroSerializer in the connection parameters and avro files have been placed under schema package/schemas directory, then avro file names would be available for key schema/value schema.