ConnectionMaster · pull · Mar 11, 2026 · Mar 11, 2026 · Mar 11, 2026 · Mar 11, 2026
diff --git a/.builders/images/linux-aarch64/build_script.sh b/.builders/images/linux-aarch64/build_script.sh
@@ -21,9 +21,8 @@ if [[ "${DD_BUILD_PYTHON_VERSION}" == "3" ]]; then
     LDFLAGS="${LDFLAGS} -L/usr/local/lib -lkrb5 -lgssapi_krb5 -llmdb" \
     DOWNLOAD_URL="https://github.com/confluentinc/librdkafka/archive/refs/tags/v{{version}}.tar.gz" \
         VERSION="${kafka_version}" \
-        SHA256="3bd351601d8ebcbc99b9a1316cae1b83b00edbcf9411c34287edf1791c507600" \
+        SHA256="14972092e4115f6e99f798a7cb420cbf6daa0c73502b3c52ae42fb5b418eea8f" \
         RELATIVE_PATH="librdkafka-{{version}}" \
-        PATCHES="0001-Avoid-includes-intended-to-bring-getentropy-in-when-.patch" \
         bash install-from-source.sh --enable-sasl --enable-curl
     always_build+=("confluent-kafka")
 

diff --git a/.builders/images/linux-x86_64/build_script.sh b/.builders/images/linux-x86_64/build_script.sh
@@ -18,9 +18,8 @@ if [[ "${DD_BUILD_PYTHON_VERSION}" == "3" ]]; then
     LDFLAGS="${LDFLAGS} -L/usr/local/lib -lkrb5 -lgssapi_krb5 -llmdb" \
     DOWNLOAD_URL="https://github.com/confluentinc/librdkafka/archive/refs/tags/v{{version}}.tar.gz" \
         VERSION="${kafka_version}" \
-        SHA256="3bd351601d8ebcbc99b9a1316cae1b83b00edbcf9411c34287edf1791c507600" \
+        SHA256="14972092e4115f6e99f798a7cb420cbf6daa0c73502b3c52ae42fb5b418eea8f" \
         RELATIVE_PATH="librdkafka-{{version}}" \
-        PATCHES="0001-Avoid-includes-intended-to-bring-getentropy-in-when-.patch" \
         bash install-from-source.sh --enable-sasl --enable-curl
     always_build+=("confluent-kafka")
 

diff --git a/.builders/images/macos/extra_build.sh b/.builders/images/macos/extra_build.sh
@@ -13,7 +13,7 @@ if [[ "${DD_BUILD_PYTHON_VERSION}" == "3" ]]; then
     LDFLAGS="${LDFLAGS} -L${DD_PREFIX_PATH}/lib -lgssapi_krb5 -llmdb" \
     DOWNLOAD_URL="https://github.com/confluentinc/librdkafka/archive/refs/tags/v{{version}}.tar.gz" \
       VERSION="${kafka_version}" \
-      SHA256="3bd351601d8ebcbc99b9a1316cae1b83b00edbcf9411c34287edf1791c507600" \
+      SHA256="14972092e4115f6e99f798a7cb420cbf6daa0c73502b3c52ae42fb5b418eea8f" \
       RELATIVE_PATH="librdkafka-{{version}}" \
       bash install-from-source.sh --prefix="${DD_PREFIX_PATH}" --enable-sasl --enable-curl
 

diff --git a/.builders/images/windows-x86_64/build_script.ps1 b/.builders/images/windows-x86_64/build_script.ps1
@@ -12,7 +12,7 @@ Write-Host "Will build librdkafka $kafka_version"
 Get-RemoteFile `
   -Uri "https://github.com/confluentinc/librdkafka/archive/refs/tags/v${kafka_version}.tar.gz" `
   -Path "librdkafka-${kafka_version}.tar.gz" `
-  -Hash '3bd351601d8ebcbc99b9a1316cae1b83b00edbcf9411c34287edf1791c507600'
+  -Hash '14972092e4115f6e99f798a7cb420cbf6daa0c73502b3c52ae42fb5b418eea8f'
 7z x "librdkafka-${kafka_version}.tar.gz" -o"C:\"
 7z x "C:\librdkafka-${kafka_version}.tar" -o"C:\librdkafka"
 Remove-Item "librdkafka-${kafka_version}.tar.gz"

diff --git a/.builders/patches/0001-Avoid-includes-intended-to-bring-getentropy-in-when-.patch b/.builders/patches/0001-Avoid-includes-intended-to-bring-getentropy-in-when-.patch
diff --git a/.ddev/ci/scripts/kafka_consumer/linux/32_install_kerberos.sh b/.ddev/ci/scripts/kafka_consumer/linux/32_install_kerberos.sh
@@ -8,7 +8,7 @@ sudo apt install -y --no-install-recommends build-essential libkrb5-dev wget sof
 # Install librdkafka from source since no binaries are available for the distribution we use on the CI:
 git clone https://github.com/confluentinc/librdkafka
 cd librdkafka
-git checkout v2.13.0
+git checkout v2.13.2
 sudo ./configure --install-deps --prefix=/usr
 make
 sudo make install

diff --git a/agent_requirements.in b/agent_requirements.in
@@ -9,7 +9,7 @@ botocore==1.42.63
 cachetools==7.0.4
 clickhouse-connect==0.13.0
 cm-client==45.0.4
-confluent-kafka==2.13.0
+confluent-kafka==2.13.2
 cryptography==46.0.5
 ddtrace==4.5.1
 dnspython==2.8.0

diff --git a/anyscale/assets/dataflows.yaml b/anyscale/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: anyscale-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: anyscale-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/celery/assets/configuration/spec.yaml b/celery/assets/configuration/spec.yaml
@@ -15,3 +15,8 @@ files:
         openmetrics_endpoint.description: |
           Endpoint exposing the Celery Flower's Prometheus metrics. For more information refer to:
           https://docs.celeryq.dev/en/stable/userguide/monitoring.html#flower-real-time-celery-web-monitor
+  - template: logs
+    example:
+    - type: file
+      path: /var/log/celery/*.log
+      source: celery
diff --git a/celery/changelog.d/22881.added b/celery/changelog.d/22881.added
@@ -0,0 +1 @@
+Add logs config to Celery integration
diff --git a/celery/datadog_checks/celery/data/conf.yaml.example b/celery/datadog_checks/celery/data/conf.yaml.example
@@ -640,3 +640,23 @@ instances:
     #   - <INCLUDE_REGEX>
     #   exclude:
     #   - <EXCLUDE_REGEX>
+
+## Log Section
+##
+## type - required - Type of log input source (tcp / udp / file / windows_event).
+## port / path / channel_path - required - Set port if type is tcp or udp.
+##                                         Set path if type is file.
+##                                         Set channel_path if type is windows_event.
+## source  - required - Attribute that defines which integration sent the logs.
+## encoding - optional - For file specifies the file encoding. Default is utf-8. Other
+##                       possible values are utf-16-le and utf-16-be.
+## service - optional - The name of the service that generates the log.
+##                      Overrides any `service` defined in the `init_config` section.
+## tags - optional - Add tags to the collected logs.
+##
+## Discover Datadog log collection: https://docs.datadoghq.com/logs/log_collection/
+#
+# logs:
+#   - type: file
+#     path: /var/log/celery/*.log
+#     source: celery
diff --git a/checkpoint_quantum_firewall/assets/dataflows.yaml b/checkpoint_quantum_firewall/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: checkpoint-quantum-firewall-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/cisco_secure_firewall/assets/dataflows.yaml b/cisco_secure_firewall/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: cisco-secure-firewall-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/falco/assets/dataflows.yaml b/falco/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: falco-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: falco-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/gunicorn/assets/dataflows.yaml b/gunicorn/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: gunicorn-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: gunicorn-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/haproxy/assets/dataflows.yaml b/haproxy/assets/dataflows.yaml
@@ -0,0 +1,13 @@
+provides:
+  - id: haproxy-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: haproxy-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
+  - id: haproxy-events
+    always_on: true
+    data_type: events
+    direction: inbound
diff --git a/harbor/assets/dataflows.yaml b/harbor/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: harbor-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: harbor-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hazelcast/assets/dataflows.yaml b/hazelcast/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hazelcast-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hazelcast-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hdfs_datanode/assets/dataflows.yaml b/hdfs_datanode/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hdfs-datanode-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hdfs-datanode-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hdfs_namenode/assets/dataflows.yaml b/hdfs_namenode/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hdfs-namenode-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hdfs-namenode-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hive/assets/dataflows.yaml b/hive/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hive-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hive-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hivemq/assets/dataflows.yaml b/hivemq/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hivemq-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hivemq-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/http_check/assets/dataflows.yaml b/http_check/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: network-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
diff --git a/hudi/assets/dataflows.yaml b/hudi/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hudi-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hudi-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/hugging_face_tgi/assets/dataflows.yaml b/hugging_face_tgi/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: hugging-face-tgi-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: hugging-face-tgi-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/iam_access_analyzer/assets/dataflows.yaml b/iam_access_analyzer/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: iam-access-analyzer-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ibm_ace/assets/dataflows.yaml b/ibm_ace/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: ibm-ace-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ibm-ace-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ibm_db2/assets/dataflows.yaml b/ibm_db2/assets/dataflows.yaml
@@ -0,0 +1,13 @@
+provides:
+  - id: ibm-db2-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ibm-db2-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
+  - id: ibm-db2-events
+    always_on: true
+    data_type: events
+    direction: inbound
diff --git a/ibm_i/assets/dataflows.yaml b/ibm_i/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: ibm-i-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
diff --git a/ibm_mq/assets/dataflows.yaml b/ibm_mq/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: ibm-mq-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ibm-mq-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ibm_spectrum_lsf/assets/dataflows.yaml b/ibm_spectrum_lsf/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: ibm-spectrum-lsf-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ibm-spectrum-lsf-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ibm_was/assets/dataflows.yaml b/ibm_was/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: ibm-was-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ibm-was-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ide_shepherd/assets/dataflows.yaml b/ide_shepherd/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: ide-shepherd-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/ignite/assets/dataflows.yaml b/ignite/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: ignite-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: ignite-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/impala/assets/dataflows.yaml b/impala/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: impala-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: impala-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/infiniband/assets/dataflows.yaml b/infiniband/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: infiniband-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
diff --git a/intercom/assets/dataflows.yaml b/intercom/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: intercom-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/istio/assets/dataflows.yaml b/istio/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: istio-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
diff --git a/ivanti_connect_secure/assets/dataflows.yaml b/ivanti_connect_secure/assets/dataflows.yaml
@@ -0,0 +1,5 @@
+provides:
+  - id: ivanti-connect-secure-logs
+    always_on: false
+    data_type: logs
+    direction: inbound
diff --git a/jboss_wildfly/assets/dataflows.yaml b/jboss_wildfly/assets/dataflows.yaml
@@ -0,0 +1,9 @@
+provides:
+  - id: jboss-wildfly-metrics
+    always_on: true
+    data_type: metrics
+    direction: inbound
+  - id: jboss-wildfly-logs
+    always_on: false
+    data_type: logs
+    direction: inbound