Interface LinkConfigManager

public interface LinkConfigManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	alterLinkConfigs(String clusterId, String linkName, List<io.confluent.kafkarest.entities.AlterConfigCommand> commands, boolean validateOnly)	Atomically alters the Kafka Link Configs according to commands.
CompletableFuture<Optional<LinkConfig>>	getLinkConfig(String clusterId, String linkName, String name)	Returns the Kafka LinkConfig with the given name.
CompletableFuture<List<LinkConfig>>	listLinkConfigs(String clusterId, String linkName)	Returns a list of Kafka LinkConfigs belonging to the Link with the given LinkName.
CompletableFuture<Void>	resetLinkConfig(String clusterId, String linkName, String name)	Resets the Kafka LinkConfig with the given name to its default value.
CompletableFuture<Void>	updateLinkConfig(String clusterId, String linkName, String name, String newValue)	Updates the Kafka LinkConfig with the given name to the given newValue.

Method Details

listLinkConfigs

CompletableFuture<List<LinkConfig>> listLinkConfigs(String clusterId,
 String linkName)

Returns a list of Kafka LinkConfigs belonging to the Link with the given LinkName.

getLinkConfig

CompletableFuture<Optional<LinkConfig>> getLinkConfig(String clusterId,
 String linkName,
 String name)

Returns the Kafka LinkConfig with the given name.

updateLinkConfig

CompletableFuture<Void> updateLinkConfig(String clusterId,
 String linkName,
 String name,
 String newValue)

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

resetLinkConfig

CompletableFuture<Void> resetLinkConfig(String clusterId,
 String linkName,
 String name)

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

alterLinkConfigs

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

Atomically alters the Kafka Link Configs according to commands.