You can use several types of plugins together with your connectors. Here are all the supported plugins supported.

​

Common Plugins supported by all connectors

​

Transforms

Related documentation: https://kafka.apache.org/documentation/#connect_transforms

org.apache.kafka.connect.transforms.Cast$Key org.apache.kafka.connect.transforms.Cast$Value org.apache.kafka.connect.transforms.DropHeaders org.apache.kafka.connect.transforms.ExtractField$Key org.apache.kafka.connect.transforms.ExtractField$Value org.apache.kafka.connect.transforms.Filter org.apache.kafka.connect.transforms.Flatten$Key org.apache.kafka.connect.transforms.Flatten$Value org.apache.kafka.connect.transforms.HeaderFrom$Key org.apache.kafka.connect.transforms.HeaderFrom$Value org.apache.kafka.connect.transforms.HoistField$Key org.apache.kafka.connect.transforms.HoistField$Value org.apache.kafka.connect.transforms.InsertField$Key org.apache.kafka.connect.transforms.InsertField$Value org.apache.kafka.connect.transforms.InsertHeader org.apache.kafka.connect.transforms.MaskField$Key org.apache.kafka.connect.transforms.MaskField$Value org.apache.kafka.connect.transforms.RegexRouter org.apache.kafka.connect.transforms.ReplaceField$Key org.apache.kafka.connect.transforms.ReplaceField$Value org.apache.kafka.connect.transforms.SetSchemaMetadata$Key org.apache.kafka.connect.transforms.SetSchemaMetadata$Value org.apache.kafka.connect.transforms.TimestampConverter$Key org.apache.kafka.connect.transforms.TimestampConverter$Value org.apache.kafka.connect.transforms.TimestampRouter org.apache.kafka.connect.transforms.ValueToKey

​

Predicates

Related documentation: https://kafka.apache.org/documentation/#connect_predicates

org.apache.kafka.connect.transforms.predicates.HasHeaderKey org.apache.kafka.connect.transforms.predicates.RecordIsTombstone org.apache.kafka.connect.transforms.predicates.TopicNameMatches

​

Converters

org.apache.kafka.connect.converters.ByteArrayConverter org.apache.kafka.connect.converters.DoubleConverter org.apache.kafka.connect.converters.FloatConverter org.apache.kafka.connect.converters.IntegerConverter org.apache.kafka.connect.converters.LongConverter org.apache.kafka.connect.converters.ShortConverter org.apache.kafka.connect.json.JsonConverter org.apache.kafka.connect.storage.StringConverter org.apache.kafka.connect.storage.SimpleHeaderConverter io.confluent.connect.avro.AvroConverter

​

Plugins Supported By Only Debezium Connectors

​

Transforms

Related documentation: https://debezium.io/documentation/reference/stable/transformations/index.html

io.debezium.connector.mongodb.transforms.ExtractNewDocumentState io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter io.debezium.connector.mysql.transforms.ReadToInsertEvent io.debezium.transforms.ByLogicalTableRouter io.debezium.transforms.ExtractChangedRecordState io.debezium.transforms.ExtractNewRecordState io.debezium.transforms.HeaderToValue io.debezium.transforms.UnwrapFromEnvelope io.debezium.transforms.outbox.EventRouter io.debezium.transforms.partitions.ComputePartition io.debezium.transforms.partitions.PartitionRouting

​

Converters

io.debezium.converters.BinaryDataConverter io.debezium.converters.ByteArrayConverter io.debezium.converters.ByteBufferConverter io.debezium.converters.CloudEventsConverter

​

Plugins Supported By Only Debezium Mongo Connector

​

Transforms

Related documentation: https://debezium.io/documentation/reference/stable/transformations/index.html

io.debezium.connector.mongodb.transforms.ExtractNewDocumentState io.debezium.connector.mongodb.transforms.outbox.MongoEventRouter

​

Plugins Supported By Only Snowflake Sink Connector

​

Converters

com.snowflake.kafka.connector.records.SnowflakeAvroConverter com.snowflake.kafka.connector.records.SnowflakeAvroConverterWithoutSchemaRegistry com.snowflake.kafka.connector.records.SnowflakeJsonConverter