Sentry Kafka SASL

Hi, We use self-hosted Sentry and external Kafka cluster with SASL security protocol.

I’m configured sentry.conf.py , by adding DEFAULT_KAFKA_OPTIONS

   "sasl.mechanism": env('KAFKA_SASL_MECHANISM'),
 "sasl.username": env('KAFKA_SASL_PLAIN_USERNAME'),
"sasl.password": env('KAFKA_SASL_PLAIN_PASSWORD'),
"security.protocol": 'env ('KAFKA_SECURITY_PROTOCOL'),
"ssl.ca.location": env('KAFKA_SSL_CA_LOCATION'),

Bot still faced with these errors:

subscription-consumer-events_1        | %6|1622025448.681|FAIL|rdkafka#producer-2| [thrd:hostname:9091/bootstrap]: hostname:9091/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 2ms in state APIVERSION_QUERY, 4 identical error(s) suppressed)
subscription-consumer-transactions_1  | %6|1622025452.319|FAIL|rdkafka#consumer-1| [thrd:hostname:9091/bootstrap]:hostname:9091/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 3ms in state APIVERSION_QUERY, 4 identical error(s) suppressed)
ingest-consumer_1                     | %6|1622025453.247|FAIL|rdkafka#producer-1| [thrd:hostname:9091/bootstrap]: hostname:9091/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 2ms in state APIVERSION_QUERY, 4 identical error(s) suppressed)
subscription-consumer-events_1        | %6|1622025454.368|FAIL|rdkafka#consumer-1| [thrd:hostname:9091/bootstrap]: hostname:9091/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 3ms in state APIVERSION_QUERY, 3 identical error(s) suppressed)
post-process-forwarder_1              | %6|1622025454.427|FAIL|rdkafka#consumer-1| [thrd:hostname:9091/bootstrap]: hostname:9091/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 3ms in state APIVERSION_QUERY, 4 identical error(s) suppressed)

Please tell me what I’m doing wrong

solved

1 Like

Would you mind sharing your solution?