{"action":"created","issue":{"url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/41","labels_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/41/labels{/name}","comments_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/41/comments","events_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/41/events","html_url":"https://github.com/softwaremill/reactive-kafka/issues/41","id":109499462,"number":41,"title":"Error handling","user":{"login":"alexanderzafirov","id":8957630,"avatar_url":"https://avatars.githubusercontent.com/u/8957630?v=3","gravatar_id":"","url":"https://api.github.com/users/alexanderzafirov","html_url":"https://github.com/alexanderzafirov","followers_url":"https://api.github.com/users/alexanderzafirov/followers","following_url":"https://api.github.com/users/alexanderzafirov/following{/other_user}","gists_url":"https://api.github.com/users/alexanderzafirov/gists{/gist_id}","starred_url":"https://api.github.com/users/alexanderzafirov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/alexanderzafirov/subscriptions","organizations_url":"https://api.github.com/users/alexanderzafirov/orgs","repos_url":"https://api.github.com/users/alexanderzafirov/repos","events_url":"https://api.github.com/users/alexanderzafirov/events{/privacy}","received_events_url":"https://api.github.com/users/alexanderzafirov/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":3,"created_at":"2015-10-02T14:19:09Z","updated_at":"2015-10-07T11:35:42Z","closed_at":null,"body":"We streaming Twitter data from a service called GNIP suddenly I get a \r\n\r\n```\r\nERROR [lt-dispatcher-2] c.s.r.k.KafkaActorSubscriber Stopping Kafka subscriber due to fatal error. WARNING arguments left: 1\r\n```\r\n\r\nAs I read in order to understand what is happening I need to implement error handling with actors.\r\nI would like some help on the example. Can someone show me how I can create a sink from the actor that supervises the KafkaActorSubscriber child?"},"comment":{"url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/comments/146163180","html_url":"https://github.com/softwaremill/reactive-kafka/issues/41#issuecomment-146163180","issue_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/41","id":146163180,"user":{"login":"alexanderzafirov","id":8957630,"avatar_url":"https://avatars.githubusercontent.com/u/8957630?v=3","gravatar_id":"","url":"https://api.github.com/users/alexanderzafirov","html_url":"https://github.com/alexanderzafirov","followers_url":"https://api.github.com/users/alexanderzafirov/followers","following_url":"https://api.github.com/users/alexanderzafirov/following{/other_user}","gists_url":"https://api.github.com/users/alexanderzafirov/gists{/gist_id}","starred_url":"https://api.github.com/users/alexanderzafirov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/alexanderzafirov/subscriptions","organizations_url":"https://api.github.com/users/alexanderzafirov/orgs","repos_url":"https://api.github.com/users/alexanderzafirov/repos","events_url":"https://api.github.com/users/alexanderzafirov/events{/privacy}","received_events_url":"https://api.github.com/users/alexanderzafirov/received_events","type":"User","site_admin":false},"created_at":"2015-10-07T11:35:42Z","updated_at":"2015-10-07T11:35:42Z","body":"According to [this](http://groovyjavathoughts.blogspot.dk/2015/01/why-am-i-getting-warning-arguments-left.html) you are missing a ```{}``` in [KafkaActorSubscriber](https://github.com/softwaremill/reactive-kafka/blob/master/core/src/main/scala/com/softwaremill/react/kafka/KafkaActorSubscriber.scala#L31).\r\nShould I make a PR? "}}