Supported Connect Plugins
Upstash Kafka and Kafka Connectors have been deprecated and will be removed on March 11, 2025. 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?