THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
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 { ... } } |
...