作者 tangxvhui

添加 kafka 配置

package constant
import "os"
var KAFKA_HOSTS = "1.116.151.79:9092" // 1.116.151.79:9092
var KAFKA_BOSS_GROUP_ID = "boss_appointment_dev"
var KAFKA_BUSINESS_ADMIN_TOPIC = "mmm-business-admin-dev"
var KAFKA_BOSS_APPOINTMENT_TOPIC = "mmm-boss-appointment-dev"
func init() {
if os.Getenv("KAFKA_HOSTS") != "" {
KAFKA_HOSTS = os.Getenv("KAFKA_HOSTS")
}
if os.Getenv("KAFKA_BUSINESS_ADMIN_TOPIC") != "" {
KAFKA_BUSINESS_ADMIN_TOPIC = os.Getenv("KAFKA_BUSINESS_ADMIN_TOPIC")
}
if os.Getenv("KAFKA_BOSS_GROUP_ID") != "" {
KAFKA_BOSS_GROUP_ID = os.Getenv("KAFKA_BOSS_GROUP_ID")
}
if os.Getenv("KAFKA_BOSS_APPOINTMENT_TOPIC") != "" {
KAFKA_BOSS_APPOINTMENT_TOPIC = os.Getenv("KAFKA_BOSS_APPOINTMENT_TOPIC")
}
}
... ...
//go:build local
package constant
var KAFKA_HOSTS = "127.0.0.1:9092" // 1.116.151.79:9092
var KAFKA_BOSS_GROUP_ID = "performance"
var KAFKA_BUSINESS_ADMIN_TOPIC = "mmm-business-admin-dev"
... ...
... ... @@ -2,13 +2,7 @@ package constant
import "os"
// var POSTGRESQL_DB_NAME = "sg-storage"
// var POSTGRESQL_USER = "postgres"
// var POSTGRESQL_PASSWORD = "123456"
// var POSTGRESQL_HOST = "127.0.0.1"
// var POSTGRESQL_PORT = "5432"
var POSTGRESQL_DB_NAME = "sg_storage_local"
var POSTGRESQL_DB_NAME = "performance_dev"
var POSTGRESQL_USER = "postgres"
var POSTGRESQL_PASSWORD = "eagle1010"
var POSTGRESQL_HOST = "114.55.200.59"
... ...