feat: 实现Apache Kafka消息队列专业扫描插件

- 新增Kafka插件支持9092等端口扫描
- 实现SASL PLAIN认证机制支持
- 支持弱密码暴力破解和服务识别功能
- 延迟连接设计避免SASL握手错误
- 支持Consumer和Client双重连接验证
- 完善Kafka相关国际化消息支持
- 兼容新插件架构设计模式

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",

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"