Я пытаюсь отправить сообщение (файл json) в тему Kafka (опубликовать) и использовать имя файла или uuid в качестве ключа kafka, чтобы я мог отслеживать его в журналах. сообщение отправляется и используется позже, но я не могу отследить ключ в журналах, чтобы я мог отследить и идентифицировать сообщения. Цель состоит в том, чтобы иметь уникальный идентификатор для каждого сообщения (используя разные имя файла / uuid для каждого события).
Я попытался использовать процесс evaluteJsonPath в Nifi, чтобы добавить имя файла в качестве атрибута, чтобы его можно было использовать, но все еще не смог найти ничего в журналах kafka. Вдобавок я изменил конфигурацию на режим отладки в журналах kafka =, но это не помогло
