Я недавно пытаюсь поиграть с потоковой передачей кафки для обработки некоторых конфиденциальных данных. Цель, которую я хочу достичь sh, заключается в том, чтобы в то время как конфиденциальные данные были зашифрованы, мощь микросервисной архитектуры не подвергается опасности, т. Е. Сервисы со слабой связью и потоковая обработка данных.
Мой вопрос в потоковой передаче kafka Возможно ли, чтобы я расшифровал входящее сообщение одним ключом и снова зашифровал его другим ключом? У меня вроде есть план, но, поскольку я не знаком с потоковой передачей kafka, я не могу доказать, что потоковая передача kafka способна обрабатывать эту функцию, используя Streams DSL. Может ли кто-нибудь помочь мне с этим вопросом, и, предпочтительно, скажите, какая функция в Streams DSL может с этим справиться?
Обновление: В основном, я спрашиваю: я пытаюсь дважды использовать шифрование ключа publi c для одного сообщения в потоковом конвейере. Один раз на входящей топике c и один раз на исходящей топи c. Просто не уверен, что DSL может расшифровать и зашифровать, и где следует хранить ключи.
Спасибо!