Configuring Bulk Produce Service for Apache Kafka
The Bulk Produce service delivers a set of messages asynchronously to a specified Kafka topic and waits for the set of messages to complete. The Bulk Produce service returns a list of metadata containing the status of each message.
The Bulk Produce service creates message objects from input signature properties, which then becomes the input document. You specify input signature properties when you configure the Bulk Produce service.
Note:
If a valid partition is specified in the input signature, 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 Bulk Produce service
1. In Designer, right-click the package where you want to create the service 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 Apache Kafka Producer Connection and click Next.
5. From the list of available templates, select the Bulk 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. In the Bulk Publish tab, configure the following fields:
Field | Description |
Topic | Specifies the topic to which the message must be published. |
Partition (optional) | Specifies the partition in which the message must be stored. |
Maximum Message Size | Specifies the maximum number of messages that can be published. |