Uploaded image for project: 'OpenShift Logging'
  1. OpenShift Logging
  2. LOG-5177

compression is not enable for kafka output

XMLWordPrintable

    • False
    • None
    • False
    • NEW
    • OBSDA-549 - Reliability and performance tuning for log collection
    • NEW
    • Release Note Not Required
    • Log Collection - Sprint 250
    • Moderate

      Description of problem:

      compression is not enable for kafka output.
      According to https://vector.dev/docs/reference/configuration/sinks/kafka/#compression. kafka plugin support the following compression methods.

      gzip
      lz4
      none
      snappy
      zstd	
      

      How reproducible:

      Always

      Steps to Reproduce:

      #Deploy CLF with tuning options

      cat <<EOF |  oc apply -f -
      apiVersion: logging.openshift.io/v1
      kind: ClusterLogForwarder
      metadata:
        name:  clf-logs
      spec:
        inputs:
        - application:
            namespaces:
            - project-qa-1
          name: myLogsQA
        outputs:
          - name: kafka-app
            url: tcp://my-cluster-kafka-bootstrap.amq-aosqe.svc:9092/topic-logging-app
            type: kafka
            secret:
              name: to-kafka-secret
            tuning:
              compression: 'gzip'
              delivery: AtMostOnce
              maxWrite: 10M
              minRetryDuration: 5
              maxRetryDuration: 10
        pipelines:
        - inputRefs:
          - myLogsQA
          name:  pipe1
          outputRefs:
          - kafka-app
        serviceAccountName: clf-to-kafka
      EOF
      
      1. check the vector.toml
      2. ...

      Actual results:

      Expected results:

      compression: xx is added in vector.toml
      Add lz4 to tuning.compression value list

      Additional info:

            rh-ee-calee Calvin Lee
            rhn-support-anli Anping Li
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: