You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
23 lines
727 B
23 lines
727 B
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Tiobon.Core.Common;
|
|
using Tiobon.Core.EventBus;
|
|
|
|
namespace Tiobon.Core.Extensions;
|
|
|
|
/// <summary>
|
|
/// 注入Kafka相关配置
|
|
/// </summary>
|
|
public static class KafkaSetup
|
|
{
|
|
public static void AddKafkaSetup(this IServiceCollection services,IConfiguration configuration)
|
|
{
|
|
if (services == null) throw new ArgumentNullException(nameof(services));
|
|
|
|
if (AppSettings.app(new string[] { "Kafka", "Enabled" }).ObjToBool())
|
|
{
|
|
services.Configure<KafkaOptions>(configuration.GetSection("kafka"));
|
|
services.AddSingleton<IKafkaConnectionPool,KafkaConnectionPool>();
|
|
}
|
|
}
|
|
}
|
|
|