Я отправляю данные из Kafka в Couchbase, используя соединитель приемника kafka (https://github.com/apache/kafka & https://github.com/couchbase/kafka-connect-couchbase). Я использую CB v5.1.0 и kafka 2.12
Я не включил ни одноговид генерации documentId в kafka connect (в файле quickstart-couchbase-sink.properties). Итак, коннектор использует весь документ в качестве ключа. Я хочу создать ключ как topic-partition-offset-randomString-timestamp.
Как этого добиться? Я мог бы найти что-то здесь - https://docs.confluent.io/current/connect/kafka-connect-elasticsearch/configuration_options.html, но нигде не вижу опции key.ignore в коде kafka и kafka-connect.