Kafka Connectors have been deprecated and will be removed on October, 1st 2024. Please refer to the deprecation notice for more information.

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

Was this page helpful?

IntroductionTroubleshooting