4.3
Brokers
Lenses uses Kafka consumers and producers. The prefix lenses.kafka.settings.client can be used to set properties.
Key | Description | Type | Required |
---|---|---|---|
lenses.kafka.brokers | A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. Add a few broker addresses here and Lenses will bootstrap and discover the full cluster membership (which may change dynamically). | string | yes |
lenses.kafka.settings.client.security.protocol | Protocol, PLAINTEXT, SSL, SASL_SSL, PLAINTEXT_SASL | string | yes |
lenses.kafka.settings.client.ssl.truststore.location | Path to the truststore | string | no |
lenses.kafka.settings.client.ssl.truststore.password | Password for the truststore | string | no |
lenses.kafka.settings.client.ssl.keystore.location | Path to the keystore | string | no |
lenses.kafka.settings.client.ssl.keystore.password | Password for the keystore | string | no |
lenses.kafka.settings.client.ssl.key.password | Key password | string | no |
Broker Metrics
Key | Description | Type | Required |
---|---|---|---|
lenses.kafka.metrics.ssl | Flag for if SSL is enabled | boolean | no |
lenses.kafka.metrics.user | User name if secure | string | no |
lenses.kafka.metrics.password | Password if secure | string | no |
lenses.kafka.metrics.type | JMX type, JMX, JOLOKIAG, or JOLOKIAP. JMX - Java Management Extensions is more common Jolokia supports two APIs a GET and a POST based one. Use JOLOKIAG if the metrics are exposed via GET requests. Use JOLOKIAP if the metrics are exposed via POST requests. | string | true |