Если вы подключаетесь к кластеру Kafka, используя TLS (с security.protocol
установленным SSL), весь трафик (включая сообщения) между вашим клиентом и Kafka шифруется.
Тем не менее, это касается только подключения к Кафке. Когда-то на брокерах Kafka, данные в незашифрованном виде. В зависимости от конфигурации вашего кластера он может храниться на зашифрованных дисках или нет.
Если вы хотите, чтобы данные были зашифрованы от начала до конца, вам придется зашифровать их на стороне производителя и отправить зашифрованные данные в Kafka. Затем, когда потребитель получит его, вам придется его расшифровать.