Configuring a Synchronous Confluent Kafka Listener Notification
Perform the following procedure to configure a synchronous Confluent Kafka listener notification:
2. Start Designer.
3. Perform the following:
a. Right-click the package in which the notification should be contained and select New > Adapter Notification.
b. Select the parent namespace and type a name for the adapter notification.
c. Click Next.
4. Select webMethods Adapter for Apache Kafka as the adapter type and click Next.
5. Select Confluent Kafka Listener Notification (synchronous) as the template and click Next.
6. Select the appropriate Notification Listener Name and click Next.
7. Select the appropriate service node and click Next.
8. Review the Request Document Name and Reply Document Name and click Finish.
The following items are created:
A listener notification
A ReplyDocument
A RequestDocument
9. In the Confluent Sync Listener Notification tab, provide values to the following fields:
Parameter | Description/Action |
Key Schema | Schema file defining the structure for keys in messages received from Confluent Kafka. The Key Schema is populated if the Key Deserializer Class is set to io.confluent.kafka.serializers.KafkaAvroDeserializer in the connection parameters. |
Value Schema | Schema file defining the structure for values in messages received from Confluent Kafka. The Value Schema is populated if the Value Deserializer Class is set to io.confluent.kafka.serializers.KafkaAvroDeserializer in the connection parameters. |
The non-editable fields outputParameterNames and outputFieldTypes are populated based on the files selected in Key Schema and Value Schema fields. The structure will reflect in the RequestDocument.
10. In the Adapter Settings tab, confirm the adapter name, adapter listener name, and adapter notification template.
11. Select the Adapter Settings tab > Execution Mode section, perform one of the following procedures:
To invoke a flow service directly, select
Service Invoke and specify the
Service Name field as the name of the service that you selected when you initially configured the adapter listener notification. You can select a different service by clicking the browse icon
to the right of the
Service Name field.
Important:
Before you select a different service, make sure that you have disabled the notification. When the notification is enabled, then the new service is utilized. For more information on enabling and disabling listeners, see
Enabling Listeners and
Disabling Listeners.
To publish documents locally or to a
Universal Messaging and wait for a reply, select
Publish and Wait and specify the following fields:
Local - Select
true to publish documents locally to
Integration Server only. Select
false to publish to the
Universal Messaging connected to
Integration Server. If no
Universal Messaging is configured for
Integration Server, documents will be published locally
Wait Time - Specify the number of milliseconds to wait for a reply. Default value is
-1, which means to wait indefinitely.
12. From the File menu, select Save.