Kafka Capture Point

The integrated Kafka Capture Point is used to capture interactions from systems that use Kafka as a message bus.

Prerequisites

The following prerequisites must be met in order to enable the Kafka Capture Point functionality in Interaction Server:

• Licensing: Interaction Server will enable Kafka Capture Point functionality only if the technical license (iwd_jms_cp) is present.
• Interaction Server 8.5.305+ must be installed.
• Existing Kafka cluster must be present. It should be running brokers of version “0.10.1.0” or newer.
• Minimum JRE 8 is required.
• OpenJDK 11 is recommended.
• Kafka is supported by using Java Kafka client and requires Java in order to work. If Java is not installed or not properly configured, Kafka functionality will not be available. All required jar files are provided in IP. These jars should be correctly specified in the Java Class Path option in Interaction Server. See Java configuration.

Outline

• Configuring
  • Start with the general procedure for creating a Capture Point Application object and a Capture Point Service.
  • Set configuration options for your particular environment.
  • Consult specific examples of configuring Kafka Capture Points, listed in the next section.
• XML Representation—The integrated Kafka Capture Point is capable of capturing interactions in the form of XML documents from the [Apache] Kafka messaging system. Consult the description of inbound and outbound XML messages.

Kafka Capture Point, just like JMS Capture Point, provides the following guarantees:

• "At least once" processing of the inbound messages including sending replies to them.
• "At most once" sending of the unsolicited notification events.

Kafka Capture Point supports secured communications via TLS protocols.

Sample Configuration

This guide provides sample configurations for Kafka Capture Point application.