{"action":"created","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/712","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/712/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/712/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/712/events","html_url":"https://github.com/spring-cloud/spring-cloud-stream/issues/712","id":188693331,"number":712,"title":"Dispatcher has no subscribers for a conusmer","user":{"login":"wooder79","id":6256522,"avatar_url":"https://avatars.githubusercontent.com/u/6256522?v=3","gravatar_id":"","url":"https://api.github.com/users/wooder79","html_url":"https://github.com/wooder79","followers_url":"https://api.github.com/users/wooder79/followers","following_url":"https://api.github.com/users/wooder79/following{/other_user}","gists_url":"https://api.github.com/users/wooder79/gists{/gist_id}","starred_url":"https://api.github.com/users/wooder79/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/wooder79/subscriptions","organizations_url":"https://api.github.com/users/wooder79/orgs","repos_url":"https://api.github.com/users/wooder79/repos","events_url":"https://api.github.com/users/wooder79/events{/privacy}","received_events_url":"https://api.github.com/users/wooder79/received_events","type":"User","site_admin":false},"labels":[{"id":233923553,"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/labels/question","name":"question","color":"cc317c","default":true},{"id":464777152,"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/labels/ready","name":"ready","color":"5319e7","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":2,"created_at":"2016-11-11T06:23:16Z","updated_at":"2016-11-16T15:12:51Z","closed_at":null,"body":"Hi,\r\n\r\nI've got an application where I'm trying to consume from a kafka topic. It looks like everything is set up fine, but every time I put a message in the configured topic, I get the following exception:\r\n\r\n```\r\n2016-11-11 00:19:13,602 -ERROR o.s.k.listener.LoggingErrorHandler - Error while processing: ConsumerRecord(topic = breakthroughSessionTopic, partition = 0, offset = 2, key = null, value = [B@36ba90f4)\r\norg.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'consumer'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers\r\n        at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:81)\r\n        at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423)\r\n        at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:373)\r\n        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)\r\n        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)\r\n        at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)\r\n        at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:292)\r\n        at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:212)\r\n        at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:129)\r\n        at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:115)\r\n        at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)\r\n        at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:70)\r\n        at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:64)\r\n        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)\r\n        at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)\r\n        at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)\r\n        at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:171)\r\n        at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$000(KafkaMessageDrivenChannelAdapter.java:47)\r\n        at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:197)\r\n        at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:76)\r\n        at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:71)\r\n        at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:276)\r\n        at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:172)\r\n        at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter.onMessage(RetryingAcknowledgingMessageListenerAdapter.java:71)\r\n        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:597)\r\n        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.access$1800(KafkaMessageListenerContainer.java:222)\r\n        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer$ListenerInvoker.run(KafkaMessageListenerContainer.java:778)\r\n        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\r\n        at java.util.concurrent.FutureTask.run(FutureTask.java:266)\r\n        at java.lang.Thread.run(Thread.java:745)\r\nCaused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers\r\n        at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:154)\r\n        at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)\r\n        at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77)\r\n        ... 29 common frames omitted\r\n```\r\n\r\nI have an `@Output` channel configured and a `@StreamListener` set to use the name of the channel. My `application.yaml` is set up with the right topic and channel names.\r\n\r\nSomehow, the relevant `@StreamListener` method doesn't seem to be called. As mentioned above, the app is receiving messages from kafka, it just doesn't seem to know where to send them.\r\n\r\nThoughts on how to resolve?"},"comment":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/comments/260970356","html_url":"https://github.com/spring-cloud/spring-cloud-stream/issues/712#issuecomment-260970356","issue_url":"https://api.github.com/repos/spring-cloud/spring-cloud-stream/issues/712","id":260970356,"user":{"login":"mbogoevici","id":159684,"avatar_url":"https://avatars.githubusercontent.com/u/159684?v=3","gravatar_id":"","url":"https://api.github.com/users/mbogoevici","html_url":"https://github.com/mbogoevici","followers_url":"https://api.github.com/users/mbogoevici/followers","following_url":"https://api.github.com/users/mbogoevici/following{/other_user}","gists_url":"https://api.github.com/users/mbogoevici/gists{/gist_id}","starred_url":"https://api.github.com/users/mbogoevici/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mbogoevici/subscriptions","organizations_url":"https://api.github.com/users/mbogoevici/orgs","repos_url":"https://api.github.com/users/mbogoevici/repos","events_url":"https://api.github.com/users/mbogoevici/events{/privacy}","received_events_url":"https://api.github.com/users/mbogoevici/received_events","type":"User","site_admin":false},"created_at":"2016-11-16T15:12:51Z","updated_at":"2016-11-16T15:12:51Z","body":"Can you share your configuration, please? `@Service` is meta-annotated with `@Component` so they should be equivalent. Looks like the bean doesn't get picked up, but it's hard to tell why without more context. "}}
{"actor":{"display_login":"mbogoevici"}}