diff --git a/apis/fluentbit/v1alpha2/plugins/output/forward_types.go b/apis/fluentbit/v1alpha2/plugins/output/forward_types.go
index cac9cc0f7..0ea04ed57 100644
--- a/apis/fluentbit/v1alpha2/plugins/output/forward_types.go
+++ b/apis/fluentbit/v1alpha2/plugins/output/forward_types.go
@@ -30,6 +30,9 @@ type Forward struct {
 	// Enables at-least-once and receiving server can control rate of traffic.
 	// (Requires Fluentd v0.14.0+ server)
 	RequireAckResponse *bool `json:"requireAckResponse,omitempty"`
+	// Set payload compression mechanism. Option available is 'gzip'
+	// +kubebuilder:validation:Enum=gzip
+	Compress string `json:"compress,omitempty"`
 	// A key string known by the remote Fluentd used for authorization.
 	SharedKey string `json:"sharedKey,omitempty"`
 	// Use this option to connect to Fluentd with a zero-length secret.
@@ -70,6 +73,9 @@ func (f *Forward) Params(sl plugins.SecretLoader) (*params.KVs, error) {
 	if f.RequireAckResponse != nil {
 		kvs.Insert("Require_ack_response", fmt.Sprint(*f.RequireAckResponse))
 	}
+	if f.Compress != nil {
+		kvs.Insert("Compress", fmt.Sprint(*f.Compress))
+	}
 	if f.SharedKey != "" {
 		kvs.Insert("Shared_Key", f.SharedKey)
 	}
diff --git a/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml b/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml
index a8ad2998a..f67e1cc5b 100644
--- a/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml
+++ b/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml
@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
diff --git a/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml b/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml
index d99653d39..29750806c 100644
--- a/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml
+++ b/charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml
@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
diff --git a/config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml b/config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml
index a8ad2998a..f67e1cc5b 100644
--- a/config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml
+++ b/config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml
@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
diff --git a/config/crd/bases/fluentbit.fluent.io_outputs.yaml b/config/crd/bases/fluentbit.fluent.io_outputs.yaml
index d99653d39..29750806c 100644
--- a/config/crd/bases/fluentbit.fluent.io_outputs.yaml
+++ b/config/crd/bases/fluentbit.fluent.io_outputs.yaml
@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
diff --git a/docs/plugins/fluentbit/output/forward.md b/docs/plugins/fluentbit/output/forward.md
index f58e0d095..4622faf1e 100644
--- a/docs/plugins/fluentbit/output/forward.md
+++ b/docs/plugins/fluentbit/output/forward.md
@@ -10,6 +10,7 @@ Forward is the protocol used by Fluentd to route messages between peers. <br />
 | tag | Overwrite the tag as we transmit. This allows the receiving pipeline start fresh, or to attribute source. | string |
 | timeAsInteger | Set timestamps in integer format, it enable compatibility mode for Fluentd v0.12 series. | *bool |
 | sendOptions | Always send options (with \"size\"=count of messages) | *bool |
+| compress | Set payload compression mechanism. Option available is 'gzip' | string |
 | requireAckResponse | Send \"chunk\"-option and wait for \"ack\" response from server. Enables at-least-once and receiving server can control rate of traffic. (Requires Fluentd v0.14.0+ server) | *bool |
 | sharedKey | A key string known by the remote Fluentd used for authorization. | string |
 | emptySharedKey | Use this option to connect to Fluentd with a zero-length secret. | *bool |
diff --git a/manifests/setup/fluent-operator-crd.yaml b/manifests/setup/fluent-operator-crd.yaml
index ab042655d..8743ac364 100644
--- a/manifests/setup/fluent-operator-crd.yaml
+++ b/manifests/setup/fluent-operator-crd.yaml
@@ -5196,6 +5196,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available 
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
@@ -34026,6 +34032,11 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
diff --git a/manifests/setup/setup.yaml b/manifests/setup/setup.yaml
index 8f0bde87b..d1c22fab9 100644
--- a/manifests/setup/setup.yaml
+++ b/manifests/setup/setup.yaml
@@ -5196,6 +5196,10 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available 
+                      is 'gzip'
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
@@ -34026,6 +34030,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.