TencentOS Server 4: kafka (TSSA-2025:0475)

#%NASL_MIN_LEVEL 80900
##
# (C) Tenable, Inc.
#
# The descriptive text and package checks in this plugin were
# extracted from Tencent Linux Security Advisory TSSA-2025:0475.
##

include('compat.inc');

if (description)
{
  script_id(276292);
  script_version("1.2");
  script_set_attribute(attribute:"plugin_modification_date", value:"2025/12/04");

  script_cve_id("CVE-2025-27817", "CVE-2025-27818");

  script_name(english:"TencentOS Server 4: kafka (TSSA-2025:0475)");

  script_set_attribute(attribute:"synopsis", value:
"The remote TencentOS Server 4 host is missing one or more security updates.");
  script_set_attribute(attribute:"description", value:
"The version of Tencent Linux installed on the remote TencentOS Server 4 host is prior to tested version. It is,
therefore, affected by multiple vulnerabilities as referenced in the TSSA-2025:0475 advisory.

    Package updates are available for TencentOS Server 4 that fix the following vulnerabilities:

    CVE-2025-27818:
    A possible security vulnerability has been identified in Apache Kafka.
    This requires access to a alterConfig to thecluster resource, or Kafka Connect worker, and the ability
    to create/modify connectors on it with an arbitrary Kafka client SASL JAAS config
    and a SASL-based security protocol, which has been possible on Kafka clusters since Apache Kafka 2.0.0
    (Kafka Connect 2.3.0).
    When configuring the broker via config file or AlterConfig command, or connector via the Kafka Kafka
    Connect REST API, an authenticated operatorcan set the `sasl.jaas.config`
    property for any of the connector's Kafka clients to com.sun.security.auth.module.LdapLoginModule, which
    can be done via the
    `producer.override.sasl.jaas.config`, `consumer.override.sasl.jaas.config`, or
    `admin.override.sasl.jaas.config` properties.
    This will allow the server to connect to the attacker's LDAP server
    and deserialize the LDAP response, which the attacker can use to execute java deserialization gadget
    chains on the Kafka connect server.
    Attacker can cause unrestricted deserialization of untrusted data (or) RCE vulnerability when there are
    gadgets in the classpath.

    Since Apache Kafka 3.0.0, users are allowed to specify these properties in connector configurations for
    Kafka Connect clusters running with out-of-the-box
    configurations. Before Apache Kafka 3.0.0, users may not specify these properties unless the Kafka Connect
    cluster has been reconfigured with a connector
    client override policy that permits them.

    Since Apache Kafka 3.9.1/4.0.0, we have added a system property
    (-Dorg.apache.kafka.disallowed.login.modules) to disable the problematic login modules usage
    in SASL JAAS configuration. Also by default
    com.sun.security.auth.module.JndiLoginModule,com.sun.security.auth.module.LdapLoginModule are disabled
    in Apache Kafka Connect 3.9.1/4.0.0.

    We advise the Kafka users to validate connector configurations and only allow trusted LDAP configurations.
    Also examine connector dependencies for
    vulnerable versions and either upgrade their connectors, upgrading that specific dependency, or removing
    the connectors as options for remediation. Finally,
    in addition to leveraging the org.apache.kafka.disallowed.login.modules system property, Kafka Connect
    users can also implement their own connector
    client config override policy, which can be used to control which Kafka client properties can be
    overridden directly in a connector config and which cannot.

    CVE-2025-27817:
    A possible arbitrary file read and SSRF vulnerability has been identified in Apache Kafka Client. Apache
    Kafka Clients accept configuration data for setting the SASL/OAUTHBEARER connection with the brokers,
    including sasl.oauthbearer.token.endpoint.url and sasl.oauthbearer.jwks.endpoint.url. Apache Kafka
    allows clients to read an arbitrary file and return the content in the error log, or sending requests to
    an unintended location. In applications where Apache Kafka Clients configurations can be specified by an
    untrusted party, attackers may use the sasl.oauthbearer.token.endpoint.url and
    sasl.oauthbearer.jwks.endpoint.url configuratin to read arbitrary contents of the disk and environment
    variables or make requests to an unintended location. In particular, this flaw may be used in Apache Kafka
    Connect to escalate from REST API access to filesystem/environment/URL access, which may be undesirable in
    certain environments, including SaaS products.

    Since Apache Kafka 3.9.1/4.0.0, we have added a system property
    (-Dorg.apache.kafka.sasl.oauthbearer.allowed.urls) to set the allowed urls in SASL JAAS configuration.
    In 3.9.1, it accepts all urls by default for backward compatibility. However in 4.0.0 and newer, the
    default value is empty list and users have to set the allowed urls explicitly.

Tenable has extracted the preceding description block directly from the Tencent Linux security advisory.

Note that Nessus has not tested for these issues but has instead relied only on the application's self-reported version
number.");
  script_set_attribute(attribute:"see_also", value:"https://mirrors.tencent.com/tlinux/errata/tssa-20250475.xml");
  script_set_attribute(attribute:"solution", value:
"Update the affected packages.");
  script_set_cvss_base_vector("CVSS2#AV:N/AC:L/Au:N/C:C/I:C/A:N");
  script_set_cvss_temporal_vector("CVSS2#E:POC/RL:OF/RC:C");
  script_set_cvss3_base_vector("CVSS:3.0/AV:N/AC:L/PR:L/UI:N/S:U/C:H/I:H/A:H");
  script_set_cvss3_temporal_vector("CVSS:3.0/E:P/RL:O/RC:C");
  script_set_attribute(attribute:"cvss4_vector", value:"CVSS:4.0/AV:N/AC:L/AT:N/PR:L/UI:N/VC:H/VI:H/VA:N/SC:N/SI:N/SA:N");
  script_set_attribute(attribute:"cvss4_threat_vector", value:"CVSS:4.0/E:P");
  script_set_attribute(attribute:"cvss_score_source", value:"CVE-2025-27817");
  script_set_attribute(attribute:"cvss3_score_source", value:"CVE-2025-27818");

  script_set_attribute(attribute:"exploitability_ease", value:"Exploits are available");
  script_set_attribute(attribute:"exploit_available", value:"true");

  script_set_attribute(attribute:"vuln_publication_date", value:"2025/06/10");
  script_set_attribute(attribute:"patch_publication_date", value:"2025/07/08");
  script_set_attribute(attribute:"plugin_publication_date", value:"2025/11/20");

  script_set_attribute(attribute:"plugin_type", value:"local");
  script_set_attribute(attribute:"cpe", value:"cpe:/o:tencent:tencentos_server:4");
  script_set_attribute(attribute:"cpe", value:"p-cpe:/a:tencent:tencentos_server:kafka");
  script_set_attribute(attribute:"generated_plugin", value:"current");
  script_end_attributes();

  script_category(ACT_GATHER_INFO);
  script_family(english:"Tencent Local Security Checks");

  script_copyright(english:"This script is Copyright (C) 2025 and is owned by Tenable, Inc. or an Affiliate thereof.");

  script_dependencies("ssh_get_info2.nasl");
  script_require_keys("Host/local_checks_enabled", "Host/etc/os-release", "Host/TencentOS/rpm-list", "Host/cpu");

  exit(0);
}


include('rpm2.inc');

if (!get_kb_item('Host/local_checks_enabled')) audit(AUDIT_LOCAL_CHECKS_NOT_ENABLED);
var os_product = get_kb_item('installed_os/local/SSH/0/product');
if (isnull(os_product) || 'TencentOS' >!< os_product) audit(AUDIT_OS_NOT, 'TencentOS');
var os_version = get_kb_item('installed_os/local/SSH/0/version');
if (isnull(os_version)) audit(AUDIT_UNKNOWN_APP_VER, 'TencentOS');
if (! preg(pattern:"^4([^0-9]|$)", string:os_version)) audit(AUDIT_OS_NOT, 'TencentOS 4.x', 'TencentOS ' + os_version);

if (!get_kb_item('Host/TencentOS/rpm-list')) audit(AUDIT_PACKAGE_LIST_MISSING);

var cpu = get_kb_item('Host/cpu');
if (isnull(cpu)) audit(AUDIT_UNKNOWN_ARCH);
if ('x86_64' >!< cpu && cpu !~ "^i[3-6]86$" && 's390' >!< cpu && 'aarch64' >!< cpu) audit(AUDIT_LOCAL_CHECKS_NOT_IMPLEMENTED, 'TencentOS', cpu);

var constraints = [
  {
    'release': '4',
    'pkgs': [
      {'reference':'kafka-3.9.1-1.oc9', 'cpu':'aarch64', 'rpm_spec_vers_cmp':TRUE},
      {'reference':'kafka-3.9.1-1.oc9', 'cpu':'x86_64', 'rpm_spec_vers_cmp':TRUE}
    ]
  }
];

var os_release = get_one_kb_item('installed_os/local/SSH/0/release');
var os_sp = get_one_kb_item('Host/*/minor_release');

var flag = 0;
var reference;
var sp;
var _cpu;
var el_string;
var rpm_spec_vers_cmp;
var epoch;
var allowmaj;
var exists_check;
var cves;
foreach var constraint ( constraints ) {
  # Check that the target release is equal to the affected release
  if (!empty_or_null(constraint['release'])){
    if (constraint['release'] != os_release) continue;
  }
  if (!empty_or_null(constraint['sp'])){
    if (constraint['sp'] != os_sp) continue;
  }
  foreach var pkg ( constraint['pkgs'] ) {
    reference = NULL;
    sp = NULL;
    _cpu = NULL;
    el_string = NULL;
    rpm_spec_vers_cmp = NULL;
    epoch = NULL;
    allowmaj = NULL;
    exists_check = NULL;
    cves = NULL;
    if (!empty_or_null(pkg['reference'])) reference = pkg['reference'];
    if (!empty_or_null(pkg['sp'])) sp = pkg['sp'];
    if (!empty_or_null(pkg['cpu'])) _cpu = pkg['cpu'];
    if (!empty_or_null(pkg['el_string'])) el_string = pkg['el_string'];
    if (!empty_or_null(pkg['rpm_spec_vers_cmp'])) rpm_spec_vers_cmp = pkg['rpm_spec_vers_cmp'];
    if (!empty_or_null(pkg['epoch'])) epoch = pkg['epoch'];
    if (!empty_or_null(pkg['allowmaj'])) allowmaj = pkg['allowmaj'];
    if (!empty_or_null(pkg['exists_check'])) exists_check = pkg['exists_check'];
    if (!empty_or_null(pkg['cves'])) cves = pkg['cves'];
    if (reference &&
        ## (no known rpm to check OR known rpm_exists)
        (!exists_check || rpm_exists(rpm:exists_check)) &&
        rpm_check(sp:sp, cpu:_cpu, reference:reference, epoch:epoch, el_string:el_string, rpm_spec_vers_cmp:rpm_spec_vers_cmp, allowmaj:allowmaj, cves:cves)) flag++;
  }
}

if (flag)
{
  security_report_v4(
      port       : 0,
      severity   : SECURITY_HOLE,
      extra      : rpm_report_get()
  );
  exit(0);
}
else
{
  var tested = pkg_tests_get();
  if (tested) audit(AUDIT_PACKAGE_NOT_AFFECTED, tested);
  else audit(AUDIT_PACKAGE_NOT_INSTALLED, 'kafka');
}