ОШИБКА Обнаружена недопустимая ошибка документа при выполнении пакета 606 из 1 записей.Ошибка была [{"type": "mapper_parsing_exception", "reason": "не удалось проанализировать", "reason_by": {"type": "invalid_argument_exception", "reason": "имя не может быть пустой строкой"}}] (чтобы игнорировать будущие записи, подобные этой, измените свойство конфигурации "% s" с "% s" на "% s").(io.confluent.connect.elasticsearch.bulk.BulkProcessor: 422)
Что я исследовал, в основном эта ошибка возникает, когда мы пытаемся отправить данные json
в ES с пустым полем имени.но данные, которые я пытаюсь опубликовать, выгружаются в ES без муравьиной ошибки при отправке из REST-Client, но при выводе данных через kafka
коннектор приемника выдает ошибку.
Я использую конфлюент 5.0.0 длямой случай.