Chapter 132. KafkaBridgeConsumerSpec schema reference
Used in: KafkaBridgeSpec
Full list of KafkaBridgeConsumerSpec
schema properties
Configures consumer options for the Kafka Bridge.
Example Kafka Bridge consumer configuration
Use the consumer.config
properties to configure Kafka options for the consumer 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 consumers.
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)
- Consumer group identifier
Properties with the following prefixes cannot be set:
-
bootstrap.servers
-
group.id
-
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 Kafka Bridge, including the following exceptions to the options configured by Streams for Apache Kafka:
-
Any
ssl
configuration for supported TLS versions and cipher suites
The Cluster Operator does not validate keys or values in the config
object. If an invalid configuration is provided, the Kafka Bridge deployment 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 Kafka Bridge nodes.
132.1. KafkaBridgeConsumerSpec schema properties Copy linkLink copied to clipboard!
Property | Property type | Description |
---|---|---|
enabled | boolean |
Whether the HTTP consumer should be enabled or disabled. The default is enabled ( |
timeoutSeconds | integer | The timeout in seconds for deleting inactive consumers, default is -1 (disabled). |
config | map | The Kafka consumer configuration used for consumer instances created by the bridge. Properties with the following prefixes cannot be set: ssl., bootstrap.servers, group.id, sasl., security. (with the exception of: ssl.endpoint.identification.algorithm, ssl.cipher.suites, ssl.protocol, ssl.enabled.protocols). |