Package io.debezium.schema

Class DefaultRegexTopicNamingStrategy

java.lang.Object

io.debezium.schema.AbstractTopicNamingStrategy<io.debezium.spi.schema.DataCollectionId>

io.debezium.schema.AbstractRegexTopicNamingStrategy

io.debezium.schema.DefaultRegexTopicNamingStrategy

All Implemented Interfaces:

io.debezium.spi.topic.TopicNamingStrategy<io.debezium.spi.schema.DataCollectionId>

@Incubating
public class DefaultRegexTopicNamingStrategy
extends AbstractRegexTopicNamingStrategy

Implement a regex expression strategy to determine data event topic names using DataCollectionId.databaseParts().

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 inherited from class io.debezium.schema.AbstractRegexTopicNamingStrategy

TOPIC_KEY_ENFORCE_UNIQUENESS, TOPIC_KEY_FIELD_NAME, TOPIC_KEY_FIELD_REGEX, TOPIC_KEY_FIELD_REPLACEMENT, TOPIC_REGEX, TOPIC_REPLACEMENT

Fields inherited from class io.debezium.schema.AbstractTopicNamingStrategy

DEFAULT_HEARTBEAT_TOPIC_PREFIX, DEFAULT_TRANSACTION_TOPIC, delimiter, heartbeatPrefix, heartbeatTopicName, multiPartitionMode, prefix, replacement, TOPIC_CACHE_SIZE, TOPIC_DELIMITER, TOPIC_HEARTBEAT_NAME, TOPIC_HEARTBEAT_PREFIX, TOPIC_TRANSACTION, topicNames, transaction

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

MAX_NAME_LENGTH, NO_SCHEMA_OP, NO_VALUE_OP

Constructor Summary

Constructors

Constructor	Description
DefaultRegexTopicNamingStrategy(Properties props)

Method Summary

Modifier and Type	Method	Description
String	getOriginTopic(io.debezium.spi.schema.DataCollectionId id)

Methods inherited from class io.debezium.schema.AbstractRegexTopicNamingStrategy

configure, dataChangeTopic, determineNewTopic, keySchemaAugment, keyValueAugment

Methods inherited from class io.debezium.schema.AbstractTopicNamingStrategy

getSchemaPartsTopicName, heartbeatTopic, isValidCharacter, mkString, sanitizedTopicName, schemaChangeTopic, transactionTopic, validateHeartbeatTopicName

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

recordSchemaPrefix

Constructor Details

DefaultRegexTopicNamingStrategy

public DefaultRegexTopicNamingStrategy(Properties props)

Method Details

getOriginTopic

public String getOriginTopic(io.debezium.spi.schema.DataCollectionId id)

Specified by:

getOriginTopic in class AbstractRegexTopicNamingStrategy