admin/JiShe.CollectBus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

添加正式环境配置文件

Browse Source
This commit is contained in:
cli 2025-05-19 08:38:09 +08:00
parent 2e58aecc2a
commit 15308fe2d7
3 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/JiShe.CollectBus.Kafka/AdminClient/AdminClientService.cs
View File

@ -154,8 +154,8 @@ public class AdminClientService : IAdminClientService, IDisposable, ISingletonDe
}; };
if (_kafkaOptionConfig.EnableAuthorization) if (_kafkaOptionConfig.EnableAuthorization)
{ {
adminClientConfig.SecurityProtocol = SecurityProtocol.SaslPlaintext; adminClientConfig.SecurityProtocol = _kafkaOptionConfig.SecurityProtocol;
adminClientConfig.SaslMechanism = SaslMechanism.Plain; adminClientConfig.SaslMechanism = _kafkaOptionConfig.SaslMechanism;
adminClientConfig.SaslUsername = _kafkaOptionConfig.SaslUserName; adminClientConfig.SaslUsername = _kafkaOptionConfig.SaslUserName;
adminClientConfig.SaslPassword = _kafkaOptionConfig.SaslPassword; adminClientConfig.SaslPassword = _kafkaOptionConfig.SaslPassword;
} }

8
web/JiShe.CollectBus.Host/CollectBusHostModule.Configure.cs
View File

@ -259,10 +259,10 @@ namespace JiShe.CollectBus.Host
.AddMongoDb(configuration.GetConnectionString("Default"), "MongoDB", HealthStatus.Unhealthy) .AddMongoDb(configuration.GetConnectionString("Default"), "MongoDB", HealthStatus.Unhealthy)
.AddRedis(configuration.GetValue<string>("Redis:Configuration") ?? string.Empty, "Redis", .AddRedis(configuration.GetValue<string>("Redis:Configuration") ?? string.Empty, "Redis",
HealthStatus.Unhealthy) HealthStatus.Unhealthy)
.AddKafka(new Confluent.Kafka.ProducerConfig //.AddKafka(new Confluent.Kafka.ProducerConfig
{ //{
BootstrapServers = configuration.GetValue<string>("Kafka:BootstrapServers") // BootstrapServers = configuration.GetValue<string>("Kafka:BootstrapServers")
}, "Kafka", failureStatus: HealthStatus.Unhealthy) //}, "Kafka", failureStatus: HealthStatus.Unhealthy)
//.AddCheck<CassandraHealthCheck>("Cassandra") //.AddCheck<CassandraHealthCheck>("Cassandra")
.AddCheck<IoTdbHealthCheck>("IoTDB"); .AddCheck<IoTdbHealthCheck>("IoTDB");

4
web/JiShe.CollectBus.Host/appsettings.Production.json
View File

@ -14,10 +14,8 @@
"BootstrapServers": "47.110.62.104:9092,47.110.53.196:9092,47.110.60.222:9092", "BootstrapServers": "47.110.62.104:9092,47.110.53.196:9092,47.110.60.222:9092",
"EnableFilter": true, "EnableFilter": true,
"EnableAuthorization": false, "EnableAuthorization": false,
"SecurityProtocol": "SaslPlaintext",
"SaslMechanism": "Plain",
"SaslUserName": "lixiao", "SaslUserName": "lixiao",
"SaslPassword": "lixiao1980", "SaslPassword": "lixiao@1980",
"KafkaReplicationFactor": 3, "KafkaReplicationFactor": 3,
"NumPartitions": 30, "NumPartitions": 30,
"ServerTagName": "JiSheCollectBus100", "ServerTagName": "JiSheCollectBus100",