Объедините значение двух полей перед публикацией в теме kafka с помощью Connect SMT

Question

Является ли ReplaceField преобразованием, используемым только для замены или маскирования имени поля. Или я могу также изменить значение поля, используя некоторое выражение со статическими значениями?

Мне нужно объединить значения двух полей перед публикацией в теме kafka.

Answer 1

org.apache.kafka.connect.transforms.InsertField используется для добавления статических значений или метаданных темы (имя темы, раздел, метка времени, смещение и т. Д.), Но не для объединения или использования выражений.

org.apache.kafka.connect.transforms.ReplaceField используется для переименования / фильтрации существующих полей, а не для добавления новых.

---

При этом вам придется создать собственный подкласс Transformation, который может объединять список полей.

Или опубликуйте существующие «необработанные» данные, а затем используйте Kafka Streams или KSQL для создания «расширенной» темы.