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

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

0 голосов
/ 24 февраля 2019

В моей текущей конфигурации я использую: HdfsSinkConnector и класс разделителя: TimeBasedPartitioner.
Разделение генерируется полем ts_ms из Debezium, равным 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 из Дебезия.
Возможно ли без записисобственный класс разделителей?

...