作者 yangfu

参数修改

@@ -10,7 +10,7 @@ var ( @@ -10,7 +10,7 @@ var (
10 // 是否启用日志收集 (本地不启用) 10 // 是否启用日志收集 (本地不启用)
11 ENABLE_KAFKA_LOG = false 11 ENABLE_KAFKA_LOG = false
12 // kafka topic up_block_chain 12 // kafka topic up_block_chain
13 - TOPIC_UP_BLOCK_CHAIN = "up_block_chain" 13 + TOPIC_UP_BLOCK_CHAIN = "allied_creation_message"
14 ) 14 )
15 15
16 func init() { 16 func init() {