Package io.debezium.schema

Class AbstractTopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

java.lang.Object

io.debezium.schema.AbstractTopicNamingStrategy<I>

All Implemented Interfaces:

io.debezium.spi.topic.TopicNamingStrategy<I>

Direct Known Subclasses:

AbstractRegexTopicNamingStrategy, AbstractUnicodeTopicNamingStrategy, DefaultTopicNamingStrategy, SchemaTopicNamingStrategy

@Incubating
public abstract class AbstractTopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>
extends Object
implements io.debezium.spi.topic.TopicNamingStrategy<I>

An abstract implementation of TopicNamingStrategy.

Author:

Harvey Yue

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.spi.topic.TopicNamingStrategy

io.debezium.spi.topic.TopicNamingStrategy.TopicSchemaAugment<S>, io.debezium.spi.topic.TopicNamingStrategy.TopicValueAugment<I extends io.debezium.spi.schema.DataCollectionId,S,R>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_HEARTBEAT_TOPIC_PREFIX
static final String	DEFAULT_TRANSACTION_TOPIC
protected String	delimiter
protected String	heartbeatPrefix
protected String	heartbeatTopicName
private static final org.slf4j.Logger	LOGGER
protected boolean	multiPartitionMode
protected String	prefix
protected io.debezium.spi.common.ReplacementFunction	replacement
static final io.debezium.config.Field	TOPIC_CACHE_SIZE
static final io.debezium.config.Field	TOPIC_DELIMITER
static final io.debezium.config.Field	TOPIC_HEARTBEAT_NAME
static final io.debezium.config.Field	TOPIC_HEARTBEAT_PREFIX
static final io.debezium.config.Field	TOPIC_TRANSACTION
protected io.debezium.util.BoundedConcurrentHashMap<I,String>	topicNames
protected String	transaction

Fields inherited from interface io.debezium.spi.topic.TopicNamingStrategy

MAX_NAME_LENGTH, NO_SCHEMA_OP, NO_VALUE_OP

Constructor Summary

Constructors

Constructor	Description
AbstractTopicNamingStrategy(Properties props)

Method Summary

Modifier and Type	Method	Description
void	configure(Properties props)
abstract String	dataChangeTopic(I id)
protected String	getSchemaPartsTopicName(io.debezium.spi.schema.DataCollectionId id)
String	heartbeatTopic()
protected boolean	isValidCharacter(char c)
protected String	mkString(List<String> data, String delimiter)
String	sanitizedTopicName(String topicName)
String	schemaChangeTopic()
String	transactionTopic()
static int	validateHeartbeatTopicName(io.debezium.config.Configuration config, io.debezium.config.Field field, io.debezium.config.Field.ValidationOutput problems)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.spi.topic.TopicNamingStrategy

keySchemaAugment, keyValueAugment, recordSchemaPrefix

Field Details

DEFAULT_HEARTBEAT_TOPIC_PREFIX

public static final String DEFAULT_HEARTBEAT_TOPIC_PREFIX

See Also:

• Constant Field Values

DEFAULT_TRANSACTION_TOPIC

public static final String DEFAULT_TRANSACTION_TOPIC

See Also:

• Constant Field Values

TOPIC_DELIMITER

public static final io.debezium.config.Field TOPIC_DELIMITER

TOPIC_CACHE_SIZE

public static final io.debezium.config.Field TOPIC_CACHE_SIZE

TOPIC_HEARTBEAT_PREFIX

public static final io.debezium.config.Field TOPIC_HEARTBEAT_PREFIX

TOPIC_HEARTBEAT_NAME

public static final io.debezium.config.Field TOPIC_HEARTBEAT_NAME

TOPIC_TRANSACTION

public static final io.debezium.config.Field TOPIC_TRANSACTION

LOGGER

private static final org.slf4j.Logger LOGGER

topicNames

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

delimiter

protected String delimiter

prefix

protected String prefix

transaction

protected String transaction

heartbeatPrefix

protected String heartbeatPrefix

heartbeatTopicName

protected String heartbeatTopicName

multiPartitionMode

protected boolean multiPartitionMode

replacement

protected io.debezium.spi.common.ReplacementFunction replacement

Constructor Details

AbstractTopicNamingStrategy

public AbstractTopicNamingStrategy(Properties props)

Method Details

configure

public void configure(Properties props)

Specified by:

configure in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

dataChangeTopic

public abstract String dataChangeTopic(I id)

Specified by:

dataChangeTopic in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

schemaChangeTopic

public String schemaChangeTopic()

Specified by:

schemaChangeTopic in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

heartbeatTopic

public String heartbeatTopic()

Specified by:

heartbeatTopic in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

transactionTopic

public String transactionTopic()

Specified by:

transactionTopic in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

sanitizedTopicName

public String sanitizedTopicName(String topicName)

Specified by:

sanitizedTopicName in interface io.debezium.spi.topic.TopicNamingStrategy<I extends io.debezium.spi.schema.DataCollectionId>

validateHeartbeatTopicName

public static int validateHeartbeatTopicName(io.debezium.config.Configuration config,
 io.debezium.config.Field field,
 io.debezium.config.Field.ValidationOutput problems)

isValidCharacter

protected boolean isValidCharacter(char c)

mkString

protected String mkString(List<String> data,
 String delimiter)

getSchemaPartsTopicName

protected String getSchemaPartsTopicName(io.debezium.spi.schema.DataCollectionId id)