Ce contenu n'est pas disponible dans la langue sélectionnée.
Chapter 121. KafkaMirrorMakerProducerSpec schema reference
Used in: KafkaMirrorMakerSpec
Full list of KafkaMirrorMakerProducerSpec schema properties
Configures a MirrorMaker producer.
121.1. abortOnSendFailure
Use the producer.abortOnSendFailure property to configure how to handle message send failure from the producer.
By default, if an error occurs when sending a message from Kafka MirrorMaker to a Kafka cluster:
- The Kafka MirrorMaker container is terminated in OpenShift.
- The container is then recreated.
If the abortOnSendFailure option is set to false, message sending errors are ignored.
121.2. config
Use the producer.config properties to configure Kafka options for the producer as keys.
The values can be one of the following JSON types:
- String
- Number
- Boolean
Exceptions
You can specify and configure the options listed in the Apache Kafka configuration documentation for producers.
However, Streams for Apache Kafka takes care of configuring and managing options related to the following, which cannot be changed:
- Kafka cluster bootstrap address
- Security (encryption, authentication, and authorization)
- Interceptors
Properties with the following prefixes cannot be set:
-
bootstrap.servers -
interceptor.classes -
sasl. -
security. -
ssl.
If the config property contains an option that cannot be changed, it is disregarded, and a warning message is logged to the Cluster Operator log file. All other supported options are forwarded to MirrorMaker, including the following exceptions to the options configured by Streams for Apache Kafka:
-
Any
sslconfiguration for supported TLS versions and cipher suites
The Cluster Operator does not validate keys or values in the config object provided. If an invalid configuration is provided, the MirrorMaker cluster might not start or might become unstable. In this case, fix the configuration so that the Cluster Operator can roll out the new configuration to all MirrorMaker nodes.
121.3. KafkaMirrorMakerProducerSpec schema properties
| Property | Property type | Description |
|---|---|---|
| bootstrapServers | string | A list of host:port pairs for establishing the initial connection to the Kafka cluster. |
| abortOnSendFailure | boolean |
Flag to set the MirrorMaker to exit on a failed send. Default value is |
| authentication |
| Authentication configuration for connecting to the cluster. |
| config | map | The MirrorMaker producer config. Properties with the following prefixes cannot be set: ssl., bootstrap.servers, sasl., security., interceptor.classes (with the exception of: ssl.endpoint.identification.algorithm, ssl.cipher.suites, ssl.protocol, ssl.enabled.protocols). |
| tls | TLS configuration for connecting MirrorMaker to the cluster. |
