Jdruker/ES KafkaCapturePointOptions
Contents
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:
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
No public options in this section.
inbound-transformer-parameters Section
No public options in this section.
notification-filtering Section
No public options in this section.
outbound-transformer-parameters Section
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.
No public options in this section.
settings Section
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.
- 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 |