Я использую соединитель приемника HDFS Kafka для записи в HDFS из kafka, он работает нормально. Мои сообщения выглядят так:
key: my-key
value: {
"name": "helen"
}
Мой вариант использования заключается в том, что мне нужно добавить ключи моего сообщения к событиям, которые я отправляю в HDFS.
Проблема в том, что ключ не отображается в полезной нагрузке значения, поэтому я не могу использовать:
"partitioner.class":
"io.confluent.connect.hdfs.partitioner.FieldPartitioner",
"partition.field.name": "key",
У меня вопрос, как я могу добавить ключ к сообщению, которое я отправляю в HDFS, или как я могу создать раздел на основе ключа?