java - Spring Cloud Stream 中的 Autowiring 问题

标签 java apache-kafka spring-cloud-stream

我正在尝试使用 Spring Cloud Stream 来实现 Kafka。我按照官方website的指示进行操作并开发了project 。当我在 IntelliJ 中运行项目时,出现以下错误

Parameter 0 of constructor in com.kafkastreams.service.GreetingsSender required a bean of type 'com.kafkastreams.stream.GreetingsStreams' that could not be found. 

我不确定我哪里做错了,任何帮助将非常感激。代码已上传至GitHub供引用。

最佳答案

GreetingsConfig 应该是一个,而不是接口(interface)

@EnableBinding(GreetingsStreams.class)
public class GreetingsConfig
{

}

关于java - Spring Cloud Stream 中的 Autowiring 问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49663393/

相关文章:

java - 无法解析我在 Spring Cloud Stream 中通过绑定(bind)器接收到的 Json 对象

java - linux下没有安装jdk如何运行JarSigner?

javascript - kafka Node js 客户端压缩问题与 snappy

apache-kafka - Apache Kafka 在 PACELC-Theorem 中的位置

message-queue - kafka多经纪人的优点

java - 处理慢速消费者 kafka 上的背压并避免重新平衡

java - 正则表达式 : How to add list as condition to satisfy regex in java

java - 在 Windows 上使用 Hadoop 2.6.0 提交作业时出错

java - 如何改变 JTextArea 中只有一个字符串的大小?

java - Azure 事件中心与 Spring Cloud Stream Kafka 的连接问题