如何使用spring引导配置文件禁用/启用合流kafka拦截器？

xjreopfe 于 2021-07-13 发布在 Java

关注(0)|答案(1)|浏览(404)

我正在编写一个使用confluent kafka replicator的spring引导应用程序，下面是我的spring引导配置文件

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

我在较低的环境中没有合流kafka replicator-例如：dev。因此，我需要一个flag/profile属性来禁用/启用上述合流kafka拦截器（consumertimestampsinterceptor）。我该怎么做？像这样的

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

spring apache-kafka spring-boot confluent-platform

来源：https://stackoverflow.com/questions/66498096/how-to-disable-enable-confluent-kafka-interceptor-using-spring-boot-profile

1条答案

按热度按时间

zpqajqem1#

您应该能够为您的spring应用程序创建一个dev概要文件（例如application-dev.yaml），然后完全删除该属性。根本没有 enabled 布尔属性
另外，您不应该需要完全嵌套，因为消费属性是平面的

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

赞(0）回复(0）举报 2021-07-13

我来回答

如何使用spring引导配置文件禁用/启用合流kafka拦截器？

1条答案

相关问题

热门标签

最新问答