当前位置: 首页 > 知识库问答 >
问题:

Kafka spring与sasl的集成授权

司徒啸
2023-03-14

我正试图通过带有SASL配置的spring集成模块连接到kafka服务器,但出现错误

JAVAlang.IllegalArgumentException:在JAAS配置中找不到“KafkaClient”条目。系统属性的java。安全auth。登录。未设置“配置”

但当我构建简单的消费者和民意调查消息时,一切都很好。有人能告诉我如何关闭JAAS授权或通过它正确连接吗。这是我的Kafka。java和SaslConfiguration。JAVA谢谢你的回答!

共有1个答案

商飞翮
2023-03-14

有一个KafkaConsumerFactory,它可以简单地接受您在要点中提到的同一组属性:https://docs.spring.io/spring-kafka/docs/2.1.10.RELEASE/reference/html/_reference.html#_receiving_messages

 类似资料:
  • 我有一个要求,在调用vertx API时,根据KeyClope对用户进行身份验证。因为我是新来的钥匙斗篷。有谁能建议我如何做到这一点吗。 提前谢谢

  • 我的想法是开始集成文件和MSSQL,这是我的知识领域。不幸的是,由于这是一个相对较新的领域,我没有找到比Facebook页面或Presto.io页面更多的东西,然而对于想要从头开始了解大数据世界的人来说,这还不够好。 我将非常感谢您在这方面的帮助和/或指导。

  • 我想使用OAuth提供程序来验证对我的kuzzle实例的请求。 做这件事的标准或首选方式是什么?

  • 我正在通过在线示例学习使用FreeMarker的SpringMVC。我遇到了这个错误,但是我不知道我的getFreemarkerConfig()方法有什么问题,一整天我都在试图修复它,但是没有成功。

  • 我试图向现有的Spring应用程序添加两个额外的表。一个正在数据库中创建,但另一个没有。我看不到JPA对象有任何明显的区别,我已经更新了这两个对象的DB属性。两个表之间唯一的主要区别是,一个表以双向关系映射到用户的表,另一个表只有一个方向。 以下是一些代码示例: 持久性.xml: data-context.xmlJPA声明: 产品实体: 支付实体: 用户实体: 账户实体: 产品表已创建 ,并链接到

  • 0.9.2 新版功能. 这些函数提高了初始化 Django 配置中环境变量的效率,运行后即可从 Django 项目或者 Django 本身中提取环境变量,而不需要每次使用 fabfile 时都亲自设置环境变量,或者使用 manage.py 插件。 目前,这些函数仅支持 Fabric 和 fabfile 以及它能引用到的 Django 库交互。听起来限制了你的使用,其实不然。在下面的例子中,你可以像