bucket notification for kafka with different sasl-mechanism

11 Jun 2025

      hi , for bucket notification anybody have experience use kafka with
encryption? i try config topic with this configuration

{
    "topics": [
        {
            "owner": "farhad",
            "name": "sre-s3",
            "dest": {
                "push_endpoint":
"kafka://sre_fkhedrian:d2Q9BAYN9RVj@10.248.17.6:9092",
                "push_endpoint_args":
"Version=2010-03-31&kafka-ack-level=broker&sasl_mechanism=SCRAM-SHA-256&security_protocol=SASL_PLAINTEXT&verify-ssl=False",
                "push_endpoint_topic": "sre-s3",
                "stored_secret": true,
                "persistent": true,
                "persistent_queue": ":sre-s3",
                "time_to_live": "None",
                "max_retries": "None",
                "retry_sleep_duration": "None"
            },
            "arn": "arn:aws:sns:podspace::sre-s3",
            "opaqueData": "",
            "policy": "",
            "subscribed_buckets": []
        }
    ]
}

 but get this error in kafka [2025-06-09 12:58:12,087] INFO [SocketServer
listenerType=BROKER, nodeId=1] Failed authentication with /10.248.35.142
(channelId=10.248.17.6:9092-10.248.35.142:40518-1-1055) (Unsupported SASL
mechanism PLAIN) (org.apache.kafka.common.network.Selector),  of course i
have use sasl_mechanism=SCRAM-SHA-256 in kafka for other program and test
with a python script i sure this working. where is problem ?how can i fix
this ?

farhad kh

tags

participants (1)