|
- //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;
-
-
- // private static readonly string[] Summaries = new[]
- // {
- // "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
- // };
-
- // private readonly ILogger<WeatherForecastController> _logger;
-
- // 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 = "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");
- // }
- // }
- //}
|