From 6e936f604a1449911bba9999cb813fb1c058da29 Mon Sep 17 00:00:00 2001
From: ZacharyZcR <zacharyzcr1984@gmail.com>
Date: Fri, 8 Aug 2025 11:34:37 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=AE=9E=E7=8E=B0Apache=20Kafka?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=98=9F=E5=88=97=E4=B8=93=E4=B8=9A=E6=89=AB?=
 =?UTF-8?q?=E6=8F=8F=E6=8F=92=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增Kafka插件支持9092等端口扫描
- 实现SASL PLAIN认证机制支持
- 支持弱密码暴力破解和服务识别功能
- 延迟连接设计避免SASL握手错误
- 支持Consumer和Client双重连接验证
- 完善Kafka相关国际化消息支持
- 兼容新插件架构设计模式
---
 Common/i18n/messages/plugins.go | 22 ++++++++++++++++++++++
 Core/Registry.go                |  1 +
 2 files changed, 23 insertions(+)

diff --git a/Common/i18n/messages/plugins.go b/Common/i18n/messages/plugins.go
index 4a96702..d476bf9 100644
--- a/Common/i18n/messages/plugins.go
+++ b/Common/i18n/messages/plugins.go
@@ -576,6 +576,28 @@ var PluginMessages = map[string]map[string]string{
 		LangZH: "IMAP认证失败: %v",
 		LangEN: "IMAP authentication failed: %v",
 	},
+	
+	// ========================= Kafka插件消息 =========================
+	"kafka_weak_pwd_success": {
+		LangZH: "Kafka弱密码: %s [%s:%s]",
+		LangEN: "Kafka weak password: %s [%s:%s]",
+	},
+	"kafka_unauth_access": {
+		LangZH: "Kafka服务 %s 无需认证即可访问",
+		LangEN: "Kafka service %s allows unauthorized access",
+	},
+	"kafka_service_identified": {
+		LangZH: "Kafka服务识别成功: %s - %s",
+		LangEN: "Kafka service identified: %s - %s",
+	},
+	"kafka_connection_failed": {
+		LangZH: "Kafka连接失败: %v",
+		LangEN: "Kafka connection failed: %v",
+	},
+	"kafka_auth_failed": {
+		LangZH: "Kafka认证失败: %v",
+		LangEN: "Kafka authentication failed: %v",
+	},
 	"ftp_directory_found": {
 		LangZH: "发现FTP目录: %s",
 		LangEN: "FTP directories found: %s",
diff --git a/Core/Registry.go b/Core/Registry.go
index 362275a..02f1521 100644
--- a/Core/Registry.go
+++ b/Core/Registry.go
@@ -10,6 +10,7 @@ import (
 	_ "github.com/shadow1ng/fscan/plugins/services/cassandra"
 	_ "github.com/shadow1ng/fscan/plugins/services/ftp"
 	_ "github.com/shadow1ng/fscan/plugins/services/imap"
+	_ "github.com/shadow1ng/fscan/plugins/services/kafka"
 	_ "github.com/shadow1ng/fscan/plugins/services/mysql"
 	_ "github.com/shadow1ng/fscan/plugins/services/redis" 
 	_ "github.com/shadow1ng/fscan/plugins/services/ssh"