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