时间戳提取器昵称设置在Spring云流应用程序不会覆盖默认值

Question

对于使用Kafka Streams绑定器的Spring Cloud Stream应用程序，我有以下属性：

spring.cloud.stream.bindings:
  windowStream-in-0:
    destination: input
  windowStream-out-0:
    destination: window1
  hint1Stream-in-0:
    destination: window1
  hint1Stream-out-0:
    destination: hints
  realityStream-in-0:
    destination: input
  realityStream-in-1:
    destination: window1
    consumer:
      timestampExtractorBeanName: anotherTimestampExtractor
  realityStream-out-0:
    destination: hints
  countStream-in-0:
    destination: hints

spring.cloud.stream.kafka.streams:
  default:
    consumer:
      timestampExtractorBeanName: timestampExtractor
  binder:
    functions:
      windowStream:
        applicationId: mock-stream-window1
      hint1Stream:
        applicationId: mock-stream-hints
      realityStream:
        applicationId: mock-stream-reality
      countStream:
        applicationId: mock-stream-count
    stateStoreRetry:
      maxAttempts: 3
      backOffInterval: 1000
    configuration:
      schema.registry.url: mock://mock-stream-registry
      default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
      default.value.serde: io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde
      commit.interval.ms: 100

我试图做的是对所有流使用“时间戳提取器”，除了一个称为“现实流”的流。

为此，我设置了＜code＞spring.cloud.stream.kafka.streams.default.consumer。timestampExtractor BeanName设置为timestampExtractor，然后尝试通过设置spring.cloud.stream.bindings.realityStream-in-1.consumer.timestampExtactor Beanname为“realityStriam”覆盖它

不幸的是，我的重写似乎不起作用，因为只有“时间戳Exrctor”被调用，正如我在调试器（和测试结果）中看到的那样。

我是应用了错误的配置，还是有错误的期望？

这是我的单个Spring Cloud Streams应用程序中的流的图片:

(橙色圆圈是我想应用非默认时间戳提取器的地方)




Answer 1

匿名用户

超驰装置在错误的地方；它需要在< code >下....Kafka . streams . bindings . reality流合一....属性。

这是Kafka特有的属性;在泛型绑定属性中（所有绑定器都通用）中具有它。