Interface GroupConfigManager

public interface GroupConfigManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	alterGroupConfigs(String clusterId, String groupId, List<io.confluent.kafkarest.entities.AlterConfigCommand> commands, boolean validateOnly)	Atomically alters the Kafka Group Configs according to commands.
CompletableFuture<Optional<GroupConfig>>	getGroupConfig(String clusterId, String groupId, String name)	Returns the Kafka GroupConfig with the given name.
CompletableFuture<List<GroupConfig>>	listGroupConfigs(String clusterId, String groupId)	Returns a list of Kafka GroupConfigs belonging to the group with the given groupId.
CompletableFuture<Void>	resetGroupConfig(String clusterId, String groupId, String name)	Resets the Kafka GroupConfig with the given name to its default value.
CompletableFuture<Void>	updateGroupConfig(String clusterId, String groupId, String name, String newValue)	Updates the Kafka GroupConfig with the given name to the given newValue.

Method Details

listGroupConfigs

CompletableFuture<List<GroupConfig>> listGroupConfigs(String clusterId,
 String groupId)

Returns a list of Kafka GroupConfigs belonging to the group with the given groupId.

getGroupConfig

CompletableFuture<Optional<GroupConfig>> getGroupConfig(String clusterId,
 String groupId,
 String name)

Returns the Kafka GroupConfig with the given name.

updateGroupConfig

CompletableFuture<Void> updateGroupConfig(String clusterId,
 String groupId,
 String name,
 String newValue)

Updates the Kafka GroupConfig with the given name to the given newValue.

resetGroupConfig

CompletableFuture<Void> resetGroupConfig(String clusterId,
 String groupId,
 String name)

Resets the Kafka GroupConfig with the given name to its default value.

alterGroupConfigs

CompletableFuture<Void> alterGroupConfigs(String clusterId,
 String groupId,
 List<io.confluent.kafkarest.entities.AlterConfigCommand> commands,
 boolean validateOnly)

Atomically alters the Kafka Group Configs according to commands.