Кафка Коннект. Возможно ли разделить данные по микросекундному полю?

В моей текущей конфигурации я использую: HdfsSinkConnector и класс разделителя: TimeBasedPartitioner,
Раздел генерируется полем ts_ms из дебезия, который millisecond,

Ниже рабочая конфигурация:

{
  "name": "connect-debezium-test-hdfs-sink",
  "config": {
    "connector.class": "io.confluent.connect.hdfs.HdfsSinkConnector",
    ...       
    "partitioner.class": "io.confluent.connect.storage.partitioner.TimeBasedPartitioner",
    "timestamp.extractor": "RecordField",
    "partition.duration.ms": "86400000",
    "path.format": "'year'=YYYY/'month'=MM/'day'=dd/",
    "timestamp.field": "ts_ms"      
  }
}

Но я хочу разделиться на основе более microsecond поле ts_usec из Дебезия.
Возможно ли это без написания собственного класса разделителя?

Источник

0 ответов

Другие вопросы по тегам