Merge branch 'lisx' into 'developer'

fix(新增jenkinsfile文件): 202301301128

See merge request !4

.gitignore

 /.idea
 *.exe
 /log
-logtransfer
-*.conf
\ No newline at end of file
+logtransfer.conf
\ No newline at end of file

logtransfer-dev.conf

+# Kafka配置
+[kafka]
+address=http://120.25.235.220:9092
+
+#Etcd配置
+[etcd]
+address=etcd0:23790,etcd1:23791
+
+#Es配置
+[es]
+address=http://47.106.69.239:9320
+bulk_size=2
\ No newline at end of file

logtransfer-main.conf

+# Kafka配置
+[kafka]
+address=http://120.25.235.220:9092
+
+#Etcd配置
+[etcd]
+address=192.168.2.129:23790,192.168.2.129:23791
+
+#Es配置
+[es]
+address=http://47.106.69.239:9320
+bulk_size=2
\ No newline at end of file

source/topic.go

@@ -17,7 +17,11 @@ func generateTopic(config TopicConfig) *Topic {
 
 	// log.Println("get config",  currentTopic.PipelineConfig)
 	for _, v := range config.PipelineConfig {
-		currentPlugin := plugin.RegistedPlugins[v.Name]
+		currentPlugin, ok := plugin.RegistedPlugins[v.Name]
+		if !ok {
+			log.Printf("get RegistedPlugins error:%s ", v.Name)
+			continue
+		}
 		err := currentPlugin.SetParams(v.Params)
 		if err != nil {
 			log.Panicln("plugin encode params error:", err)