27 lines
832 B
C#
27 lines
832 B
C#
|
using DouyinApi.Common;
|
|||
|
|
using DouyinApi.EventBus;
|
|||
|
|
using Microsoft.Extensions.Configuration;
|
|||
|
|
using Microsoft.Extensions.DependencyInjection;
|
|||
|
|
using Microsoft.Extensions.Logging;
|
|||
|
|
using System;
|
|||
|
|
|
|||
|
|
namespace DouyinApi.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>();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|