Как отправить ключ сообщения с уникальным идентификатором (eventID / UUID / filename) из Nifi в тему Kafka и посмотреть в логах kafka

Question

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

Я пытался использовать процесс evaluteJsonPath в Nifi, чтобы добавить имя файла в качестве атрибута, чтобы оно могло бытьиспользовал, но все еще не смог найти что-либо в логах кафки.Кроме того, я изменил конфигурацию на режим отладки в журналах kafka =, но это не помогло

Answer 1

Все потоковые файлы уже имеют атрибут с именем 'filename', поэтому вам не нужно использовать EvaluateJsonPath, если вы не хотите перезаписать атрибут имени файла чем-то другим, исходящим из json.

Все потоковые файлы также имеют атрибут 'uuid', поэтому вы можете использовать любой из них в процессоре publish kafka.

Конфигурация publish kafka выглядит правильно с точки зрения обращения к $ {filename}, но я понятия не имею, что логи кафки.