Package io.debezium.schema

Class TopicSelector.TopicNameCache<I extends io.debezium.spi.schema.DataCollectionId>

java.lang.Object

io.debezium.schema.TopicSelector.TopicNameCache<I>

All Implemented Interfaces:

TopicSelector.DataCollectionTopicNamer<I>

Enclosing class:

TopicSelector<I extends io.debezium.spi.schema.DataCollectionId>

@ThreadSafe
private static class TopicSelector.TopicNameCache<I extends io.debezium.spi.schema.DataCollectionId>
extends Object
implements TopicSelector.DataCollectionTopicNamer<I>

A topic namer that caches names it has obtained from a delegate.

Field Summary

Fields

Modifier and Type	Field	Description
private final TopicSelector.DataCollectionTopicNamer<I>	delegate
private final io.debezium.util.BoundedConcurrentHashMap<I,String>	topicNames

Constructor Summary

Constructors

Constructor	Description
TopicNameCache(TopicSelector.DataCollectionTopicNamer<I> delegate)

Method Summary

Modifier and Type	Method	Description
String	topicNameFor(I id, String prefix, String delimiter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

topicNames

private final io.debezium.util.BoundedConcurrentHashMap<I extends io.debezium.spi.schema.DataCollectionId,String> topicNames

delegate

private final TopicSelector.DataCollectionTopicNamer<I extends io.debezium.spi.schema.DataCollectionId> delegate

Constructor Details

TopicNameCache

TopicNameCache(TopicSelector.DataCollectionTopicNamer<I> delegate)

Method Details

topicNameFor

public String topicNameFor(I id,
 String prefix,
 String delimiter)

Specified by:

topicNameFor in interface TopicSelector.DataCollectionTopicNamer<I extends io.debezium.spi.schema.DataCollectionId>