Сжатие в PutTCP - ListenTCPRecord Связь в NiFi - PullRequest
0 голосов
/ 30 августа 2018

У меня есть особый случай использования, когда я передаю пакет сообщений JSON между двумя NiFi кластерами, используя PutTCP & ListenTCPRecord .

Есть ли способ применить сжатие к сообщениям, отправляемым через PutTCP , и распаковать сообщение в конце ListenTCPRecord ?

1 Ответ

0 голосов
/ 30 августа 2018

В настоящее время нет сжатия / распаковки, встроенной в процессоры TCP, но я думаю, что это будет разумный запрос.

Вы можете использовать CompressContent до PutTCP, но тогда я не думаю, что вы можете использовать ListenTCPRecord на принимающей стороне, поскольку он будет считывать сжатые данные в поисках записей и не найдет их, поэтому, возможно, с использованием обычного ListenTCP, а затем отправка результатов в CompressContent в режиме распаковки, а затем на любые нужные процессоры записи. Я не пробовал, хотя и не совсем уверен, работает ли он.

...