如何 disable/enable - 使用 Spring 引导配置文件融合 KAFKA 拦截器？

Question

我正在编写一个使用 Confluent KAFKA 复制器的 Spring 启动应用程序，下面是我的 Spring 启动配置文件

spring:
  kafka:
    consumer:
      properties:
        interceptor:
          classes: io.confluent.connect.replicator.offsets.ConsumerTimestampsInterceptor
        timestamp:
          producer:
            security:
              protocol: PLAINTEXT
            sasl:
              mechanism: NONE

我在下层环境中没有 Confluent KAFKA 复制器 - 例如：Dev。所以，我想要一个 flag/profile 属性到 disable/enable 上面的 Confluent KAFKA 拦截器（ConsumerTimestampsInterceptor）。我该怎么做？像这样

spring:
  kafka:
    consumer:
      properties:
        interceptor:
          enabled : false

Answer 1

您应该能够为您的 spring 应用程序创建开发配置文件（例如，application-dev.yaml），然后完全删除属性。没有 enabled 布尔值属性

此外，您不需要完全嵌套，因为消费者属性无论如何都是扁平的

spring:
  kafka:
    consumer:
      properties:
        interceptor.classes: "className"

如何 disable/enable - 使用 Spring 引导配置文件融合 KAFKA 拦截器？

How to disable/enable - Confluent KAFKA Interceptor using Spring boot profile?

spring

apache-kafka

spring-boot

confluent-platform