Page History

public enum ScramMechanismType {
    UNKNOWN(0),
    HMAC_SHA_256(1),
    HMAC_SHA_512(2);

    byte type;

    private ScramMechanismType(byte type) {
        this.type = type;
    }
}

public class ScramMechanism {
    private final ScramMechanismType type;
    private final int iterations;
    private final String password; // will be null when listing

    public static ScramMechanism parse(String str);

    public ScramMechanism(ScramMechanismType type, int iterations, String password) {
        this.type = type;
        this.iterations = iterations;
    }

    this.passwordpublic = password;
    }

    public ScramMechanismType ScramMechanismType type() {
        return type;
    }

    public int iterations() {
        return iterations;
    }

    public String password() {
        return password;
    }
}

public class ScramUserListing {
    private final String name;
    private final List<ScramMechanism> mechanism;

    public ScramUserListing(String name, List<ScramMechanism> mechanism) {
        this.name = name;
        this.mechanism = mechanism;
    }

    public String name() {
        return name;
    }

    public List<ScramMechanism> mechanism() {
        return mechanism;
    }
}

public class ListScramUsersOptions extends AbstractOptions<ListScramUsersOptions> { }

default ListScramUsersResult listScramUsers() {
    return listScramUsers(new ListScramUsersOptions());
}

ListScramUsersResult listScramUsers(ListScramUsersOptions options);

public class ListScramUsersResult {
    public KafkaFuture<Map<String, ScramUser>> all();
}

public class ScramUserDeletion {
    private final String user;

    ScramUserDeletion(String user) {
        this.user = user;
    }

    public String user() {
        return user;
    }
}

public class ScramCredential {
    private final ScramMechanism mechanism;
    private final String password;

    public static ScramCredential parse(String str);

    public ScramCredential(ScramMechanism mechanism, String password) {
        this.mechanism = mechanism;
        this.password = password;
 private final String user;}

    public ScramUserDeletion(String userScramMechanism password() {
        this.user = userreturn mechanism;
    }

    public String userpassword() {
        return userpassword;
    }
}

public class ScramUserAlteration {
    private final String user;
    private final List<ScramMechanism>List<ScramCredential> passwordcredentials;

    public ScramCredentialAlteration(String user, List<ScramMechanism>List<ScramCredential> mechanismscredentials) {
        this.user = user;
        this.mechanismscredentials = mechanismscredentials;
    }

    public String user() {
        return user;
    }

    public List<ScramMechanism>List<ScramCredential> mechanismscredentials() {
        return mechanismscredentials;
    }
}

public class AlterScramUsersOptions extends AbstractOptions<AlterScramUsersOptions> {}

default AlterScramUsersResult alterScramUsers(List<ScramUserDeletion> deletions,
                                              List<ScramUserAlteration> alterations) {
    return alterScramUsers(deletions, alterations, new AlterScramUsersOptions());
}

AlterScramUsersResult alterScramUsers(List<ScramUserDeletion> deletions,
                                      List<ScramUserAlteration> alterations,
                                      AlterScramUsersOptions options);

public class AlterScramCredentialsResult {
    public KafkaFuture<Void> all();
    public Map<String, KafkaFuture<Void>> results();
}

{ 
  "apiKey": 51, 
  "type": "response",
  "name": "AlterScramUsersRequest",
  "validVersions": "0", 
  "flexibleVersions": "0+", 
  "fields": [ 
    { "name": "Deletions", "type": "[]ScramUserDeletion", "versions": "0+",
      "about": "The SCRAM users to remove.", "fields": [
        { "name": "Name", "type": "string", "versions": "0+",
          "about": "The user name." }
      ]},
    { "name": "Alterations", "type": "[]ScramUserAlteration", "versions": "0+",
      "about": "The SCRAM users to alter.", "fields": [
      { "name": "Name", "type": "string", "versions": "0+",
        "about": "The user name." }
      { "name": "MechanismsCredentials", "type": "ScramMechanismScramCredential", "versions": "0+",
        "about": "The SCRAM mechanismscredentials to configure." }
        { "name": "TypeMechanismType", "type": "int8", "versions": "0+",
          "about": "The mechanism type." },
        { "name": "IterationsMechanismIterations", "type": "int32", "versions": "0+",
          "about": "The number of iterations, or -1 to use the server default." },
        { "name": "Password", "type": "string", "versions": "0+", ",
          "about": "The password." }
      ]}
    ]}  
  ]       
}   

{ 
  "apiKey": 51, 
  "type": "response",
  "name": "AlterScramUsersResponse",
  "validVersions": "0", 
  "flexibleVersions": "0+", 
  "fields": [ 
    { "name": "Results", "type": "[]AlterScramUsersResult", "versions": "0+",
      "about": "The results for removals, followed by the results for alterations.", "fields": [
        { "name": "ErrorCode", "type": "int8", "versions": "0+",
          "about": "The error code." },
        { "name": "ErrorString", "type": "string", "versions": "0+", "nullableVersions": "0+",
          "about": "The error message, if any." }
    ]}  
  ]       
}