Du kannst nicht mehr als 25 Themen auswählen Themen müssen entweder mit einem Buchstaben oder einer Ziffer beginnen. Sie können Bindestriche („-“) enthalten und bis zu 35 Zeichen lang sein.

WeatherForecastController.cs 2.7KB

vor 10 Monaten
vor 10 Monaten
vor 10 Monaten
vor 10 Monaten
vor 10 Monaten
vor 10 Monaten
vor 10 Monaten
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. //}