Package io.debezium.metadata

Class ComponentDescriptor

java.lang.Object

io.debezium.metadata.ComponentDescriptor

public class ComponentDescriptor
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final String	className
private static final Map<String,String>	COMPONENT_TYPE_MAPPINGS	Mapping of Kafka Connect interface names to component type identifiers.
private static final String	CONVERTER_TYPE
private static final String	CUSTOM_CONVERTER_TYPE
private final String	description
private final String	displayName
private final String	id
private static final org.slf4j.Logger	LOGGER
private static final String	PREDICATE_TYPE
private static final String	SERVER_SINK_TYPE
private static final String	SINK_CONNECTOR_TYPE
private static final String	SOURCE_CONNECTOR_TYPE
private static final String	TRANSFORMATION_TYPE
private final String	type
private static final String	UNKNOWN_TYPE
private final String	version

Constructor Summary

Constructors

Modifier	Constructor	Description
	ComponentDescriptor(String className, String version)
	ComponentDescriptor(String className, String displayName, String version)
	ComponentDescriptor(String className, String displayName, String description, String version)
private	ComponentDescriptor(String id, String displayName, String description, String className, String version, String type)

Method Summary

Modifier and Type	Method	Description
private static String	determineComponentType(String className)	Determines the component type by checking which Kafka Connect interface the class implements.
private static String	determineComponentTypeByName(String className)	Fallback method that determines component type based on class name patterns.
boolean	equals(Object that)
String	getClassName()
String	getDescription()
String	getDisplayName()
String	getId()
String	getType()
String	getVersion()
int	hashCode()
private static boolean	isAssignableFrom(Class<?> componentClass, String interfaceClassName)	Checks if the given class is assignable from the specified interface/class name.

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

SINK_CONNECTOR_TYPE

private static final String SINK_CONNECTOR_TYPE

See Also:

• Constant Field Values

SERVER_SINK_TYPE

private static final String SERVER_SINK_TYPE

See Also:

• Constant Field Values

SOURCE_CONNECTOR_TYPE

private static final String SOURCE_CONNECTOR_TYPE

See Also:

• Constant Field Values

TRANSFORMATION_TYPE

private static final String TRANSFORMATION_TYPE

See Also:

• Constant Field Values

PREDICATE_TYPE

private static final String PREDICATE_TYPE

See Also:

• Constant Field Values

CONVERTER_TYPE

private static final String CONVERTER_TYPE

See Also:

• Constant Field Values

CUSTOM_CONVERTER_TYPE

private static final String CUSTOM_CONVERTER_TYPE

See Also:

• Constant Field Values

UNKNOWN_TYPE

private static final String UNKNOWN_TYPE

See Also:

• Constant Field Values

COMPONENT_TYPE_MAPPINGS

private static final Map<String,String> COMPONENT_TYPE_MAPPINGS

Mapping of Kafka Connect interface names to component type identifiers. Checked in order, so more specific types should come first.

id

private final String id

displayName

private final String displayName

description

private final String description

className

private final String className

version

private final String version

type

private final String type

Constructor Details

ComponentDescriptor

private ComponentDescriptor(String id,
 String displayName,
 String description,
 String className,
 String version,
 String type)

ComponentDescriptor

public ComponentDescriptor(String className,
 String version)

ComponentDescriptor

public ComponentDescriptor(String className,
 String displayName,
 String version)

ComponentDescriptor

public ComponentDescriptor(String className,
 String displayName,
 String description,
 String version)

Method Details

getId

public String getId()

getDisplayName

public String getDisplayName()

getDescription

public String getDescription()

getClassName

public String getClassName()

getVersion

public String getVersion()

getType

public String getType()

determineComponentType

private static String determineComponentType(String className)

Determines the component type by checking which Kafka Connect interface the class implements. This is more reliable than string matching on class names.

Parameters:

className - the fully qualified class name

Returns:

the component type: "source-connector", "sink-connector", "transformation", "predicate", or "unknown"

determineComponentTypeByName

private static String determineComponentTypeByName(String className)

Fallback method that determines component type based on class name patterns. Used when the class cannot be loaded via reflection.

Debezium naming convention: Classes ending in "Connector" (without "Sink" prefix) are source connectors by default.

isAssignableFrom

private static boolean isAssignableFrom(Class<?> componentClass,
 String interfaceClassName)

Checks if the given class is assignable from the specified interface/class name. Returns false if the interface class cannot be loaded.

equals

public boolean equals(Object that)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object