Nevar pievienot vairāk kā 25 tēmas Tēmai ir jāsākas ar burtu vai ciparu, tā var saturēt domu zīmes ('-') un var būt līdz 35 simboliem gara.

WeatherForecastController.cs 2.7KB

pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
pirms 10 mēnešiem
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. //using Confluent.Kafka;
  2. //using Confluent.Kafka.Admin;
  3. //using Microsoft.AspNetCore.Mvc;
  4. //using TelpoKafkaConsole.Service;
  5. //using TelpoKafkaConsole.WebApi.Controllers.Api;
  6. //namespace TelpoKafkaConsole.WebApi.Controllers
  7. //{
  8. // [ApiController]
  9. // [Route("[controller]")]
  10. // public class WeatherForecastController : ControllerBase
  11. // {
  12. // private readonly KafkaAdminService _servicekafkaAdmin;
  13. // private static readonly string[] Summaries = new[]
  14. // {
  15. // "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
  16. // };
  17. // private readonly ILogger<WeatherForecastController> _logger;
  18. // public WeatherForecastController(ILogger<WeatherForecastController> logger, KafkaAdminService kafkaAdminService)
  19. // {
  20. // _logger = logger;
  21. // _servicekafkaAdmin = kafkaAdminService;
  22. // }
  23. // //[HttpGet(Name = "GetWeatherForecast")]
  24. // //public IEnumerable<WeatherForecast> Get()
  25. // //{
  26. // // return Enumerable.Range(1, 5).Select(index => new WeatherForecast
  27. // // {
  28. // // Date = DateTime.Now.AddDays(index),
  29. // // TemperatureC = Random.Shared.Next(-20, 55),
  30. // // Summary = Summaries[Random.Shared.Next(Summaries.Length)]
  31. // // })
  32. // // .ToArray();
  33. // //}
  34. // //[HttpGet(Name = "GetGroup")]
  35. // //public ApiResponse<List<GroupInfo>> GetGroup()
  36. // //{
  37. // // var group = _servicekafkaAdmin.ListGroups();
  38. // // return ApiResponse<List<GroupInfo>>.Success(group);
  39. // //}
  40. // [HttpGet(Name = "GetGroup")]
  41. // public async Task<ApiResponse<string>> GetGroupAsync()
  42. // {
  43. // // var group = _servicekafkaAdmin.ListGroups();
  44. // List<AclBinding> aclBindings = new()
  45. // {
  46. // new AclBinding()
  47. // {
  48. // Pattern = new ResourcePattern
  49. // {
  50. // Type = ResourceType.Broker,
  51. // Name = "kafka-cluster",
  52. // ResourcePatternType = ResourcePatternType.Literal
  53. // },
  54. // Entry = new AccessControlEntry
  55. // {
  56. // Principal = $"User:telpo-consumer",
  57. // Host = "*",
  58. // Operation = AclOperation.All,
  59. // PermissionType = AclPermissionType.Deny
  60. // }
  61. // }
  62. // };
  63. // await _servicekafkaAdmin.CreateAclsAsync(aclBindings);
  64. // return ApiResponse<string>.Success("ok");
  65. // }
  66. // }
  67. //}