Это бизнес-требование, чтобы все сообщения, которые я использую в теме kafka, содержали печать целостности, чтобы определить, были ли внесены какие-либо изменения в полезную нагрузку сообщения.
Я думал, что смогу сделать это в kafka connect transform. Это потребовало бы, чтобы я преобразовал полезную нагрузку в результирующий формат сообщения json в преобразовании перед его запечатыванием, чтобы результаты могли быть проверены при использовании сообщения.
Мои проблемы в настоящее время ...
1) Я не уверен, как преобразовать полезную нагрузку в тот же json, который будет выводиться в тему kafka во время преобразования.
2) Я не уверен, что лучший способ добавить печатьна сообщение. Он должен быть размещен в согласованном месте (например, сначала), чтобы его можно было легко / полностью удалить до проверки герметичности у потребителя.
Любые мысли, предложения, различные подходы будут оценены.