Documentation Kafka Connect Single Message Transformations Reference for Confluent Platform

Confluent Developer Marketplace Get started

Home Confluent Cloud Confluent Platform Connectors Clients

Kafka Connect Single Message Transformations Reference for Confluent Platform

Get started

Home Confluent Cloud Confluent Platform Connectors Clients

Overview
Cast
Drop
DropHeaders
EventRouter
ExtractField
ExtractTopic
Filter (Kafka)
Filter (Confluent)
Flatten
GzipDecompress
HeaderFrom
HoistField
InsertField
InsertHeader
MaskField
MessageTimestampRouter
RegexRouter
ReplaceField (Kafka)
ReplaceField (Confluent)
SetSchemaMetadata
TimestampConverter
TimestampRouter
TimezoneConverter
TimescaleDB
TombstoneHandler
ValueToKey
ChangeLog

Table of contents

Overview
Cast
Drop
DropHeaders
EventRouter
ExtractField
ExtractTopic
Filter (Kafka)
Filter (Confluent)
Flatten
GzipDecompress
HeaderFrom
HoistField
InsertField
InsertHeader
MaskField
MessageTimestampRouter
RegexRouter
ReplaceField (Kafka)
ReplaceField (Confluent)
SetSchemaMetadata
TimestampConverter
TimestampRouter
TimezoneConverter
TimescaleDB
TombstoneHandler
ValueToKey
ChangeLog

Kafka Connect Single Message Transformations Reference for Confluent Platform

Ask the community Confluent Support Portal Last published: Jun 20, 2026

Copyright © Confluent, Inc. 2014- Apache®, Apache Kafka®, Kafka®, Apache Flink®, Flink®, Apache Iceberg®, Iceberg® and associated open source project names are trademarks of the Apache Software Foundation