我正试图通过一个简单的spring启动应用程序（通过springcloudstreambinder-kafka-streams库）使用kafka中某个主题的消息。
我在看文件-https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/blob/master/docs/src/main/asciidoc/kafka-streams.adoc
我的代码如下：package co.zip.poc.springbootkafkakotlin

import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import org.apache.kafka.streams.kstream.KStream
import org.springframework.context.annotation.Bean
import java.util.function.Consumer

@SpringBootApplication
class SpringBootKafkaConsumer {

  @Bean
  fun process(): Consumer<KStream<Any, Any>> {
    println("=======================> Creating a consumer for reading stuff<=====================")
    return Consumer { input -> input.foreach { key, value ->
      println("============key = $key")
      println("===========value = $value")
    }}
  }
}

fun main(args: Array<String>) {
  runApplication<SpringBootKafkaConsumer>(*args)
}

应用程序.yml

spring:
  application:
    name: customer-balance
  cloud:
    stream:
      kafka:
        streams:
          binder:
            configuration:
              application:
                id: customer-balance
      bindings:
        process_in:
          destination: "dbserver1.inventory.customers"

logging:
  level:
    org.springframework.kafka.config: trace

我的Kafka在9092号港口。我可以通过Kafka控制台消费信息-

kafka-console-consumer.sh \
    --bootstrap-server localhost:9092 \
    --from-beginning \
    --property print.key=true \
    --topic dbserver1.inventory.customers

上面的代码在控制台上生成4条消息。但是当我运行springboot应用程序时，我没有得到任何打印的key=。。值=打印消息。
我做错什么了？