kafka
Connection information for accessing a kafka topic
Properties
Name | Type | Description | Notes |
---|---|---|---|
bootstrap_servers | String | A comma-separated list of host/port pairs to use for establishing the initial connection to the Kafka cluster | [default: null] |
key_deserializer | String | Deserializer to be used for the keys of the topic | [optional] [default: null] |
sasl_mechanism | String | SASL Mechanism to be used (e.g. PLAIN or SCRAM-SHA-512) | [optional] [default: SCRAM-SHA-512] |
schema_registry | String | Host/port to connect the schema registry server | [optional] [default: null] |
security_protocol | String | Kafka security protocol one of (PLAINTEXT, SASL_PLAINTEXT, SASL_SSL, SSL) | [optional] [default: SASL_SSL] |
ssl_truststore | String | A truststore or certificate encoded as base64. The format can be JKS or PKCS12. | [optional] [default: null] |
topic_name | String | Name of the Kafka topic | [default: null] |
value_deserializer | String | Deserializer to be used for the values of the topic | [optional] [default: null] |
[Back to Model list] [Back to API list] [Back to API-Specification]