Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Minor fixes from discussion thread

...

Code Block
languagejava
titleorg.apache.kafka.clients.admin
public class AdminClient {
    public ListConfigsResult listConfigs(List<ConfigEntity>Collection<ConfigEntity> entities, ListConfigsOptions options);
    public AlterConfigsResult alterConfigs(Map<ConfigEntity, List<Config>> configs, AlterConfigsOptions options);
}

public class ListConfigsOptions { 
    public ListConfigsOptions timeoutMs(Integer timeout);
}

public class ListConfigsResult {
    public KafkaFuture<Map<ConfigEntity, Config>>Collection<Config>>> all();
}
 
public class AlterConfigsOptions { 
    public AlterConfigsOptions timeoutMs(Integer timeout);
	public AlterConfigsOptions validateOnly(boolean timeoutvalidateOnly);
}

public class AlterConfigsResult {
    public KafkaFuture<Void> all();
    public Map<ConfigEntity, KafkaFuture<Void>> results();
}
 
public class ConfigEntity {
    enum Type {
		CLIENT, BROKER, TOPIC, UNKNOWN;
    }
 
    public ConfigEntity(Type type, String name) { ... }
    
    public Type type() { ... }
    public String name() { ... }
}
 
public class ConfigConfigEntry {
    public ConfigConfigEntry(String name, String value) {
        this(name, value, false, false, false);
    }
    public ConfigConfigEntry(String name, String value, boolean isDefault, boolean isSensitive, boolean isReadOnly) { ... }
    public String name() { ... }
    public String value() { ... }
    public boolean isDefault { ... }
    public boolean isSensitive { ... }
    public boolean isReadOnly { ... }
}

...