从SpringBoot 3.2版开始

公共 map <字符串,对象>BuildAdminProperties()

在3.4版中已弃用并标记为删除 https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/autoconfigure/kafka/KafkaProperties.html#buildAdminProperties()

并且建议您使用

公共映射字符串、对象&>BuildAdminProperties(SslBundles SslBundles)

当我们使用SASL_PLAYTEXT与SCRAM-SHA-512连接到Kafka集群时

  kafka:
    security:
      protocol: SASL_PLAINTEXT
    bootstrap-servers: adress_of_the_server
    properties:
      sasl:
        mechanism: SCRAM-SHA-512
        jaas:
          config: org.apache.kafka.common.security.scram.ScramLoginModule required username="username" password="password";
    jaas:
      enabled: true

我应该如何使用SCRAM-SHA-512为SASL_PLAYTEXT配置SslBundle?

推荐答案

Spring Boot为我们自动配置了KafkaAdmin.因此,最好try 在您的应用程序中依赖该Bean.如果您仍有一些特定用例需要自己创建该实例,请考虑使用KafkaProperties.buildAdminProperties(null)来获取所有这些配置属性.SslBundles是Spring Boot配置一部分,看起来确实可以为我们提供sasl配置.因此,我们只是跳过它,并依赖于您在YAML中使用这properties部分配置的任何内容.

Java相关问答推荐

Gmail Javi API批量处理太多请求

是否需要关闭Executors返回的执行器.newVirtualThreadPerTaskExecutor()?

如何使用Java API在Oracle ODI中运行模拟?

H2弹簧靴试验跌落台

如何在访问完所有文件后加入所有线程?

不推荐使用的Environment.getExternalStorageDirectory().getAbsolutePath()返回的值不同于新的getExternalFilesDir(空)?

类型集合的Jackson JsonNode:类型引用的对象读取器应该是Singleton吗?

继续收到错误SQLJDBC EXCEPTION执行";org.springframework.dao.InvalidDataAccessResourceUsageException:&

Spring-Boot Kafka应用程序到GraalVM本机映像-找不到org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier

如何将Java文档配置为在指定的项目根目录中生成?

如何在JavaFX循环中完美地制作一个AudioClip/MediaPlayer?

协同 routine 似乎并不比JVM线程占用更少的资源

TinyDB问题,无法解析符号';上下文&

为什么我的登录终结点不能被任何请求访问?

在Spring Boot中使用咖啡因进行缓存

如何使用外部函数从Java中获取C++ struct 的返回值&;内存API

如何正确使用java.time类?

错误:JOIN/ON的参数必须是boolean类型,而不是bigint类型.Java Spring启动应用程序

[Guice/MissingImplementation]:未绑定任何实现

java构造函数中的冻结操作何时发生?