Package io.debezium.converters.custom

Class CustomConverterServiceProvider

java.lang.Object

io.debezium.converters.custom.CustomConverterServiceProvider

All Implemented Interfaces:

ServiceProvider<CustomConverterRegistry>

public class CustomConverterServiceProvider
extends Object
implements ServiceProvider<CustomConverterRegistry>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONVERTER_TYPE_SUFFIX
private final ServiceLoader<CustomConverterFactory>	converterFactories

Constructor Summary

Constructors

Constructor	Description
CustomConverterServiceProvider()

Method Summary

Modifier and Type	Method	Description
private io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.ConvertedField>	createConverter(io.debezium.config.Configuration configuration, String name)
CustomConverterRegistry	createService(io.debezium.config.Configuration configuration, ServiceRegistry serviceRegistry)	Creates or provides a desired service.
Class<CustomConverterRegistry>	getServiceClass()	Get the service class that should be initiated or provided.

Methods inherited from class java.lang.Object

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

Field Details

CONVERTER_TYPE_SUFFIX

public static final String CONVERTER_TYPE_SUFFIX

See Also:

• Constant Field Values

converterFactories

private final ServiceLoader<CustomConverterFactory> converterFactories

Constructor Details

CustomConverterServiceProvider

public CustomConverterServiceProvider()

Method Details

createService

public CustomConverterRegistry createService(io.debezium.config.Configuration configuration,
 ServiceRegistry serviceRegistry)

Description copied from interface: ServiceProvider

Creates or provides a desired service.

Specified by:

createService in interface ServiceProvider<CustomConverterRegistry>

Parameters:

configuration - the connector configuration

serviceRegistry - the service registry

Returns:

the constructed service

getServiceClass

public Class<CustomConverterRegistry> getServiceClass()

Description copied from interface: ServiceProvider

Get the service class that should be initiated or provided. The service class should be unique in the registry.

Specified by:

getServiceClass in interface ServiceProvider<CustomConverterRegistry>

Returns:

the service class

createConverter

private io.debezium.spi.converter.CustomConverter<org.apache.kafka.connect.data.SchemaBuilder,io.debezium.spi.converter.ConvertedField> createConverter(io.debezium.config.Configuration configuration,
 String name)