无法在使用Spring cloud流绑定器的Spring Boot应用程序中检索KafkaStreams对象

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams</artifactId>
    <version>2.8.0</version>
</dependency>

spring.kafka.streams.application-id=my-stream-processing-app
spring.kafka.streams.bootstrap-servers=localhost:9092

@Configuration
public class KafkaStreamsConfig {

    @Value("${spring.kafka.streams.application-id}")
    private String applicationId;

    @Value("${spring.kafka.streams.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public KafkaStreams kafkaStreams() {
        Properties props = new Properties();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, applicationId);
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

        // 添加其他配置属性...

        return new KafkaStreams(topology(), props);
    }

    @Bean
    public Topology topology() {
        // 构建Kafka Streams拓扑结构
        // 添加处理逻辑...

        return builder.build();
    }
}