Package io.debezium.schema

Class SchemaUnicodeTopicNamingStrategy

java.lang.Object

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

io.debezium.schema.AbstractUnicodeTopicNamingStrategy

io.debezium.schema.SchemaUnicodeTopicNamingStrategy

All Implemented Interfaces:

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

@Incubating
public class SchemaUnicodeTopicNamingStrategy
extends AbstractUnicodeTopicNamingStrategy

Implement a unicode converter strategy to determine data event topic names using DataCollectionId.schemaParts().

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.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
SchemaUnicodeTopicNamingStrategy(Properties props)

Method Summary

Modifier and Type	Method	Description
static SchemaUnicodeTopicNamingStrategy	create(CommonConnectorConfig config)
String	dataChangeTopic(io.debezium.spi.schema.DataCollectionId id)

Methods inherited from class io.debezium.schema.AbstractUnicodeTopicNamingStrategy

isValidCharacter

Methods inherited from class io.debezium.schema.AbstractTopicNamingStrategy

configure, getSchemaPartsTopicName, heartbeatTopic, 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

keySchemaAugment, keyValueAugment, recordSchemaPrefix

Constructor Details

SchemaUnicodeTopicNamingStrategy

public SchemaUnicodeTopicNamingStrategy(Properties props)

Method Details

create

public static SchemaUnicodeTopicNamingStrategy create(CommonConnectorConfig config)

dataChangeTopic

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

Specified by:

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

Specified by:

dataChangeTopic in class AbstractTopicNamingStrategy<io.debezium.spi.schema.DataCollectionId>