我们将springcloud与streamkafka一起使用，它运行良好，但是不能访问springmvc的url，如果我删除@enablebinding（sink.class）就可以了。
似乎@enablebinding（sink.class）会影响springmvc的功能。
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
1条答案
按热度按时间au9on6nz1#
为了使应用程序能够与kafka通信，我遇到了相同的问题，需要定义一个出站流来向kafka主题写入消息，定义一个入站流来从kafka主题读取消息。
springcloud提供了一种方便的方法，只需创建一个接口，为每个流定义一个单独的方法。
似乎你的接口不在spring上下文中，你应该使用@component注解，