confluent-kafka-dotnet - 以编程方式验证 Confluent Kafka 访问权限
问题描述
我试图弄清楚是否有任何方法可以使用 Confluent Kafka lib for .NET 以编程方式检查提供的凭据是否具有对不同 Kafka 主题的读写访问权限。
我想做的基本上是在系统启动时进行冒烟测试,以验证给定的凭据是否正确。例如,当部署到具有不同设置的各种环境时。
设置一个完整的消费者或生产者,然后实际读取或写入数据似乎很麻烦且昂贵。
我认为可能有一些东西,例如AdminClient
允许验证这一点,但我没有看到任何暗示这个方向的东西。
解决方案
是的,有 AdminClient 实现,请查看以下 .NET 的 github 存储库示例
https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/examples/AdminClient/Program.cs
推荐阅读
- flutter - 保存当前路线并在 Flutter 中弹出前一条
- amazon-web-services - 从没有哈希和范围键的 DynamoDB 中找到一行并将其删除
- php - 如何指定与 Doctrine 固定装置的数据库连接?
- c - 我的功能之一是不小心从列表中删除元素
- c++ - 指针成员未在复制构造函数中初始化
- google-cloud-platform - GCP:“计算引擎未准备好”
- javascript - 计算经过的时间并将其放入 JavaScript 中的 Days:Hours:Minutes:Seconds 格式,其中经过的时间每秒更新一次
- elasticsearch - 使用弹性搜索 py 批量更新无类型
- php - MYSLI_QUERY 返回 false 但 MYSQLI_ERROR 从 5.6 更新 php 7.2 后未显示错误
- java - 如何实现一个持续活跃的循环来检查变化(布尔值)?