Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.5.1
-
None
-
None
Description
Similar to KAFKA-5150 but for zstd instead of LZ4, it appears that a large decompression buffer (128kb) created by zstd-jni per batch is causing a significant performance bottleneck.
The next upcoming version of zstd-jni (1.4.5-7) will have a new constructor for ZstdInputStream that allows the client to pass its own buffer. A similar fix as PR #2967 could be used to have the ZstdConstructor use a BufferSupplier to re-use the decompression buffer.
Attachments
Issue Links
- links to