server.port: 9998
spring.application.name: kafka-streams-confluent-consumer
spring.cloud.stream.bindings.output:
    destination: sensor-versions
spring.cloud.stream.bindings.input:
    destination: sensors
    consumer:
      useNativeDecoding: true
spring.cloud.stream.kafka.streams.binder:
    brokers: localhost
    configuration:
      schema.registry.url: http://localhost:8081
      commit.interval.ms: 1000
      default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
      default.value.serde: io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde
spring.cloud.stream.kafka.streams.bindings.input:
  consumer:
  # The following 2 props are not needed as they are same as the global ones.
  # Adding it here in order to illustrate the usage of it if they are indeed different from the global Serde's
    keySerde: org.apache.kafka.common.serialization.Serdes$StringSerde
    valueSerde: io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde
