json - PutTCP 中的压缩 - NiFi 中的 ListenTCPRecord 通信

Question

我有一个特殊的用例，我使用PutTCP和ListenTCPRecord在两个NiFi集群之间传输一批 JSON 消息。

有没有办法对通过PutTCP发送的消息应用压缩并在ListenTCPRecord端解压缩消息？

标签： jsontcpapache-nificompression

Answer 1

目前 TCP 处理器中没有内置压缩/解压缩功能，但我认为这是一个合理的要求。

您可以在 PutTCP 之前使用 CompressContent，但是我认为您不能在接收端使用 ListenTCPRecord，因为它会读取压缩数据以查找记录并且找不到它们，因此可能使用常规 ListenTCP 然后发送结果在解压缩模式下压缩内容，然后到您需要的任何记录处理器。我还没有尝试过，所以不完全确定它是否有效。