1 changed files with 67 additions and 67 deletions
+ 67
- 67
TelpoKafkaConsole.WebApi/Controllers/WeatherForecastController.cs
View File
| @@ -1,74 +1,74 @@ | |||||
| using Confluent.Kafka; | |||||
| using Confluent.Kafka.Admin; | |||||
| using Microsoft.AspNetCore.Mvc; | |||||
| using TelpoKafkaConsole.Service; | |||||
| using TelpoKafkaConsole.WebApi.Controllers.Api; | |||||
| //using Confluent.Kafka; | |||||
| //using Confluent.Kafka.Admin; | |||||
| //using Microsoft.AspNetCore.Mvc; | |||||
| //using TelpoKafkaConsole.Service; | |||||
| //using TelpoKafkaConsole.WebApi.Controllers.Api; | |||||
| namespace TelpoKafkaConsole.WebApi.Controllers | |||||
| { | |||||
| [ApiController] | |||||
| [Route("[controller]")] | |||||
| public class WeatherForecastController : ControllerBase | |||||
| { | |||||
| private readonly KafkaAdminService _servicekafkaAdmin; | |||||
| //namespace TelpoKafkaConsole.WebApi.Controllers | |||||
| //{ | |||||
| // [ApiController] | |||||
| // [Route("[controller]")] | |||||
| // public class WeatherForecastController : ControllerBase | |||||
| // { | |||||
| // private readonly KafkaAdminService _servicekafkaAdmin; | |||||
| private static readonly string[] Summaries = new[] | |||||
| { | |||||
| "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching" | |||||
| }; | |||||
| // private static readonly string[] Summaries = new[] | |||||
| // { | |||||
| // "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching" | |||||
| // }; | |||||
| private readonly ILogger<WeatherForecastController> _logger; | |||||
| // private readonly ILogger<WeatherForecastController> _logger; | |||||
| public WeatherForecastController(ILogger<WeatherForecastController> logger, KafkaAdminService kafkaAdminService) | |||||
| { | |||||
| _logger = logger; | |||||
| _servicekafkaAdmin = kafkaAdminService; | |||||
| } | |||||
| // public WeatherForecastController(ILogger<WeatherForecastController> logger, KafkaAdminService kafkaAdminService) | |||||
| // { | |||||
| // _logger = logger; | |||||
| // _servicekafkaAdmin = kafkaAdminService; | |||||
| // } | |||||
| //[HttpGet(Name = "GetWeatherForecast")] | |||||
| //public IEnumerable<WeatherForecast> Get() | |||||
| //{ | |||||
| // return Enumerable.Range(1, 5).Select(index => new WeatherForecast | |||||
| // { | |||||
| // Date = DateTime.Now.AddDays(index), | |||||
| // TemperatureC = Random.Shared.Next(-20, 55), | |||||
| // Summary = Summaries[Random.Shared.Next(Summaries.Length)] | |||||
| // }) | |||||
| // .ToArray(); | |||||
| //} | |||||
| //[HttpGet(Name = "GetGroup")] | |||||
| //public ApiResponse<List<GroupInfo>> GetGroup() | |||||
| //{ | |||||
| // var group = _servicekafkaAdmin.ListGroups(); | |||||
| // return ApiResponse<List<GroupInfo>>.Success(group); | |||||
| //} | |||||
| // //[HttpGet(Name = "GetWeatherForecast")] | |||||
| // //public IEnumerable<WeatherForecast> Get() | |||||
| // //{ | |||||
| // // return Enumerable.Range(1, 5).Select(index => new WeatherForecast | |||||
| // // { | |||||
| // // Date = DateTime.Now.AddDays(index), | |||||
| // // TemperatureC = Random.Shared.Next(-20, 55), | |||||
| // // Summary = Summaries[Random.Shared.Next(Summaries.Length)] | |||||
| // // }) | |||||
| // // .ToArray(); | |||||
| // //} | |||||
| // //[HttpGet(Name = "GetGroup")] | |||||
| // //public ApiResponse<List<GroupInfo>> GetGroup() | |||||
| // //{ | |||||
| // // var group = _servicekafkaAdmin.ListGroups(); | |||||
| // // return ApiResponse<List<GroupInfo>>.Success(group); | |||||
| // //} | |||||
| [HttpGet(Name = "GetGroup")] | |||||
| public async Task<ApiResponse<string>> GetGroupAsync() | |||||
| { | |||||
| // var group = _servicekafkaAdmin.ListGroups(); | |||||
| List<AclBinding> aclBindings = new() | |||||
| { | |||||
| new AclBinding() | |||||
| { | |||||
| Pattern = new ResourcePattern | |||||
| { | |||||
| Type = ResourceType.Broker, | |||||
| Name = "kafka-cluster", | |||||
| ResourcePatternType = ResourcePatternType.Literal | |||||
| }, | |||||
| Entry = new AccessControlEntry | |||||
| { | |||||
| Principal = $"User:telpo-consumer", | |||||
| Host = "*", | |||||
| Operation = AclOperation.All, | |||||
| PermissionType = AclPermissionType.Deny | |||||
| } | |||||
| } | |||||
| }; | |||||
| await _servicekafkaAdmin.CreateAclsAsync(aclBindings); | |||||
| return ApiResponse<string>.Success("ok"); | |||||
| } | |||||
| } | |||||
| } | |||||
| // [HttpGet(Name = "GetGroup")] | |||||
| // public async Task<ApiResponse<string>> GetGroupAsync() | |||||
| // { | |||||
| // // var group = _servicekafkaAdmin.ListGroups(); | |||||
| // List<AclBinding> aclBindings = new() | |||||
| // { | |||||
| // new AclBinding() | |||||
| // { | |||||
| // Pattern = new ResourcePattern | |||||
| // { | |||||
| // Type = ResourceType.Broker, | |||||
| // Name = "kafka-cluster", | |||||
| // ResourcePatternType = ResourcePatternType.Literal | |||||
| // }, | |||||
| // Entry = new AccessControlEntry | |||||
| // { | |||||
| // Principal = $"User:telpo-consumer", | |||||
| // Host = "*", | |||||
| // Operation = AclOperation.All, | |||||
| // PermissionType = AclPermissionType.Deny | |||||
| // } | |||||
| // } | |||||
| // }; | |||||
| // await _servicekafkaAdmin.CreateAclsAsync(aclBindings); | |||||
| // return ApiResponse<string>.Success("ok"); | |||||
| // } | |||||
| // } | |||||
| //} | |||||
Loading…