Я перемещаю данные из Kafka в Elasticsearch и использую Kafka для подключения SMT и, более конкретно, TimeStampConverter. Я возился с некоторыми из них и не мог заставить его выводить формат Timestamp.
Когда я использовал типы «Date», «Time» или «Timestamp» в качестве значений для transforms.TimestampConverter.target.type, я не мог получить данные в Elasticsearch , Только до тех пор, пока я не установил значение "строка", он выводит значения в эластичный поиск в качестве типа данных даты. К сожалению, это означает, что я могу получить значение только с точностью до дня.
Вот настройки трансформатора:
"transforms": "TimestampConverter",
"transforms.TimestampConverter.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.TimestampConverter.field": "UPDATED",
"transforms.TimestampConverter.format": "yyyy-MM-dd",
"transforms.TimestampConverter.target.type": "string"
Есть какие-нибудь известные способы, как добиться этого с более точной отметкой времени? Я перепробовал все виды конфигураций, изменив поля target.type и format
Значение ОБНОВЛЕНО - эпоха bigint