Spring Cloud 无法使用 kafka答案

【问题标题】：Spring Cloud can't work with kafkaSpring Cloud 无法使用 kafka
【发布时间】：2018-06-20 10:10:21
【问题描述】：

我们使用带有流Kafka的spring cloud，它运行良好，但无法访问spring mvc Urls，如果我删除@EnableBinding（Sink.class）它工作正常。

看来@EnableBinding(Sink.class) 会影响spring mvc 功能。

2018-01-11 15:54:19.218 [restartedMain] WARN  org.apache.kafka.clients.consumer.ConsumerConfig - The configuration 'value.serializer' was supplied but isn't a known config.
2018-01-11 15:54:19.218 [restartedMain] WARN  org.apache.kafka.clients.consumer.ConsumerConfig - The configuration 'key.serializer' was supplied but isn't a known config.
2018-01-11 15:54:19.219 [restartedMain] INFO  org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1
2018-01-11 15:54:19.219 [restartedMain] INFO  org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247

【问题讨论】：

我不确定您在这里想说什么，或者共享日志 sn-p 如何说明您所描述的问题。配置错误的可能性很大，但如果没有任何相关细节，就无法回答甚至推测可能是什么。
帮助我们识别问题的最好方法是在 GitHub 上分享一个简单的项目，并附上如何重现的自述文件

标签： apache-kafka spring-cloud spring-cloud-stream spring-kafka

【解决方案1】：

我遇到了同样的问题为了让您的应用程序能够与 Kafka 通信，需要定义一个出站流来将消息写入 Kafka 主题，并定义一个入站流来从 Kafka 主题中读取消息。

Spring Cloud 提供了一种便捷的方式来做到这一点，只需创建一个接口，为每个流定义一个单独的方法。

您的界面似乎不在 Spring 上下文中你应该使用@Component 注解，

【讨论】：