Package io.kroxylicious.proxy.filter.metadata

Interface TopicNameMapping

public interface TopicNameMapping

The result of discovering the topic names for a collection of topic ids

Field Summary

Fields

Modifier and Type	Field	Description
static final TopicNameMapping	EMPTY

Method Summary

Modifier and Type	Method	Description
default boolean	allFailures()
boolean	anyFailures()
Map<org.apache.kafka.common.Uuid,TopicNameMappingException>	failures()	Describes the reason for every failed mapping.
Map<org.apache.kafka.common.Uuid,String>	topicNames()

Field Details

EMPTY

static final TopicNameMapping EMPTY

Method Details

anyFailures

boolean anyFailures()

Returns:

true if there are any failures

allFailures

default boolean allFailures()

Returns:

true if all name mappings failed

topicNames

Map<org.apache.kafka.common.Uuid,String> topicNames()

Returns:

immutable map from topic id to successfully mapped topic name

failures

Map<org.apache.kafka.common.Uuid,TopicNameMappingException> failures()

Describes the reason for every failed mapping. Expected exception types are:

• TopLevelMetadataErrorException indicates that we attempted to obtain Metadata from upstream, but received a top-level error in the response
• TopicLevelMetadataErrorException indicates that we attempted to obtain Metadata from upstream, but received a topic-level error in the response
• TopicNameMappingException can be used to convey any other exception

All the exception types offer TopicNameMappingException.getError() for conveniently determining the cause. Unhandled exceptions will be mapped to an Errors.UNKNOWN_SERVER_ERROR. Callers will be able to use this to detect expected cases like Errors.UNKNOWN_TOPIC_ID.

Returns:

immutable map from topic id to kafka server error