def METHOD_NAME():
    source = KafkaSource(
        brokers="broker_host:9092",
        topics="mytopic",
        group="mygroup",
        sasl_user="myuser",
        sasl_pass="mypassword",
    )
    function = new_function(kind="remote")
    source.add_nuclio_trigger(function)
    attributes = function.spec.config["spec.triggers.kafka"]["attributes"]
    assert attributes["brokers"] == ["broker_host:9092"]
    assert attributes["topics"] == ["mytopic"]
    assert attributes["consumerGroup"] == "mygroup"
    assert attributes["sasl"] == {
        "enabled": True,
        "user": "myuser",
        "password": "mypassword",
    }