Я пытался изменить значение по умолчанию pk.fields для pk.mode: kafka. Тем не менее, я не смог найти никакой документации о том, какие поля для него допустимы. Я хотел, чтобы поле отметки времени вместе с разделом и смещением, как pk.fields.
Я попытался изменить pk.fields на "pk.fields": "timestamp, __connect_partition, __connect_offset". Однако метка времени всегда заменяется значением темы. Под меткой времени я подразумеваю ROWTIME
Как я могу решить эту проблему? Каковы допустимые значения для pk.fields?