Package io.gravitee.gateway.reactive.api.context.kafka.topicidentity

Interface TopicIdentityRegistry

public interface TopicIdentityRegistry

Method Summary

Modifier and Type	Method	Description
Optional<TopicIdentity>	findById(org.apache.kafka.common.Uuid id)	Find a topic identity by its id
Optional<TopicIdentity>	findByName(String name)	Find a topic identity by its name
void	put(TopicIdentity topicIdentity)	Put a topic identity in the registry

Method Details

findByName

Optional<TopicIdentity> findByName(String name)

Find a topic identity by its name

Parameters:

name - the name of the topic.

Returns:

Optional of TopicIdentity

findById

Optional<TopicIdentity> findById(org.apache.kafka.common.Uuid id)

Find a topic identity by its id

Parameters:

id - Uuid of the topic.

Returns:

Optional of TopicIdentity.

put

void put(TopicIdentity topicIdentity)

Put a topic identity in the registry

Parameters:

topicIdentity - TopicIdentity