Jdruker/ES KafkaCapturePointOptions

Kafka Capture Point

Options for the integrated Kafka Capture Point are configured in the following sections on the Options tab of the Kafka Capture Point application:

• consumer-options Section
• default-values Section
• inbound-transformer-parameters Section
• notification-filtering Section
• outbound-transformer-parameters Section
• producer-options Section
• settings Section

As the Java Kafka client used for communication with the Kafka cluster, the integrated Kafka Capture Point supports additional standard Apache Kafka configuration options, as discussed under:

• Advanced Java Kafka Client Options
• Security Configuration

consumer-options Section

In addition to the options that are defined in this section, the Integrated Kafka Capture Point supports native Apache Kafka consumer options. See Advanced Java Kafka Client Options and Security Configuration for more information.

No public options in this section.

   

default-values Section

PDF This Page

No public options in this section.

   

inbound-transformer-parameters Section

PDF This Page

No public options in this section.

   

notification-filtering Section

PDF This Page

No public options in this section.

   

outbound-transformer-parameters Section

PDF This Page

No public options in this section.

   

producer-options Section

In addition to the options that are defined in this section, the Integrated Kafka Capture Point supports native Apache Kafka producer options. See Advanced Java Kafka Client Options and Security Configuration for more information.

PDF This Page

No public options in this section.

   

settings Section

PDF This Page

No public options in this section.

   

New content follows, somewhat edited. Confirm that I haven't changed meaning incorrectly.

Advanced Java Kafka Client Options

You can customize the majority of the Java Kafka client options in the following Capture Point configuration sections:

• consumer-options - Options specified in this section are passed to the Java Kafka consumers as is. Consumers are used to read inbound messages from the Kafka cluster. The full list of Apache Kafka consumer options is on the official page.
• producer-options - Options specified in this section are passed to the Java Kafka producers as is. Producers are used to send outbound messages to the Kafka cluster. The full list of Apache Kafka producer options is on the official page.

Important

The following options in the consumer-options and producer-options sections cannot be overridden. Interaction Server ignores any values that you configure for these options.

• bootstrap.servers (settings\kafka-server) - The value of kafka-server under the settings section is passed to boostrap.servers, as Interaction Server uses the same broker for producer and consumer.
• group.id - The value of consumer-group under the settings section is passed to group.id, and its value is set to InteractionServer by default.
• enable.auto.commit - The value of this option is hardcoded to false, as Interaction Server guarantees “at least once” delivery.

Security Configuration

The Java Kafka client library provides secured communications. Refer to the official Kafka documentation for more information. Necessary options mentioned in the Kafka documentation can be set in the consumer-options and producer-options sections.

Kafka protected options

You can hide the values of the following sensitive Kafka client options by putting them into the password option in the following sections:

Original Section	Original Option	Protected Section	Protected Option
consumer-options	ssl.keystore.password	consumer-options:ssl.keystore.password	password
consumer-options	ssl.truststore.password	consumer-options:ssl.truststore.password	password
consumer-options	sasl.jaas.config	consumer-options:sasl.jaas.config	password
producer-options	ssl.keystore.password	consumer-options:ssl.keystore.password	password
producer-options	ssl.truststore.password	producer-options:ssl.truststore.password	password
producer-options	sasl.jaas.config	producer-options:sasl.jaas.config	password