Is your feature request related to a problem? Please describe.
There are currently two CompressionOption enums providing similar compression functionality. One of these CompressionOptions is used for S3 pipelines and the other is being used for KafkaBuffer. When additional compression engines are added to one CompressionOption, these changes are not reflected in the other CompressionOption.
S3 CompressionOption: org.opensearch.dataprepper.plugins.sink.s3.compression
Codec/KafkaBuffer CompressionOption: org.opensearch.dataprepper.plugins.codec
Adding ZSTD compression functionality to KafkaBuffer did not provide additional ZSTD functionality in the S3 pipeline.
Ideally, the two enums should be consolidated to reduce duplicate code.
Is your feature request related to a problem? Please describe.
There are currently two
CompressionOptionenums providing similar compression functionality. One of these CompressionOptions is used for S3 pipelines and the other is being used for KafkaBuffer. When additional compression engines are added to one CompressionOption, these changes are not reflected in the other CompressionOption.S3 CompressionOption:
org.opensearch.dataprepper.plugins.sink.s3.compressionCodec/KafkaBuffer CompressionOption:
org.opensearch.dataprepper.plugins.codecAdding ZSTD compression functionality to KafkaBuffer did not provide additional ZSTD functionality in the S3 pipeline.
Ideally, the two enums should be consolidated to reduce duplicate code.