我正在尝试使用最简单的spring云流示例,因此我决定实现参考指南中的示例。我希望它能和Kafka一起工作,所以我对两者都做了太多的申请
Spring Cloud启溪Kafka
作为一种依赖。我也试过用rabbitmq替换它
Spring Cloud始流兔
但是我不能让它工作。我没有得到任何例外,我可以看到,源放的作品,但Flume没有打印的消息。我确信它正确地连接到kafka/rabbitmq,因为我没有得到任何异常,如果我没有运行kafka/rabbitmq,我也会得到异常。我在运行应用程序时也使用destination参数(如指南中所述),因此应该使用相同的目的地。
我使用的是springboot1.4.2.release和springcloudcamden.sr2
有人知道我错过了什么吗?
暂无答案!
目前还没有任何答案,快来回答吧!