Я новичок в Kafka Connect, но пытаюсь использовать его для загрузки некоторых данных в Postgres.
Мое сообщение включает в себя два поля "epochSeconds" и "nanos", однако я хотел бы добавитьстолбец Timestamp в базе данных (отбрасывая точность наносекунды).
Итак, учитывая поля
epochSeconds nanos
1554635349 351025373
, я хочу объединить 1554635349 и 351025, затем использовать https://docs.confluent.io/current/connect/transforms/timestampconverter.html для преобразования во временную метку.
Мой вопрос заключается в том, можно ли выполнить конкатенацию (частичных) полей и преобразование результата, используя только конфигурацию.Или мне придется написать какой-нибудь Java-код?
Заранее спасибо за любой совет.