{"action":"created","issue":{"url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/29","labels_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/29/labels{/name}","comments_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/29/comments","events_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/29/events","html_url":"https://github.com/softwaremill/reactive-kafka/issues/29","id":102350130,"number":29,"title":"support error handling for KafkaActorSubscriber","user":{"login":"hepin1989","id":501740,"avatar_url":"https://avatars.githubusercontent.com/u/501740?v=3","gravatar_id":"","url":"https://api.github.com/users/hepin1989","html_url":"https://github.com/hepin1989","followers_url":"https://api.github.com/users/hepin1989/followers","following_url":"https://api.github.com/users/hepin1989/following{/other_user}","gists_url":"https://api.github.com/users/hepin1989/gists{/gist_id}","starred_url":"https://api.github.com/users/hepin1989/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hepin1989/subscriptions","organizations_url":"https://api.github.com/users/hepin1989/orgs","repos_url":"https://api.github.com/users/hepin1989/repos","events_url":"https://api.github.com/users/hepin1989/events{/privacy}","received_events_url":"https://api.github.com/users/hepin1989/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":{"url":"https://api.github.com/repos/softwaremill/reactive-kafka/milestones/1","html_url":"https://github.com/softwaremill/reactive-kafka/milestones/0.8.0","labels_url":"https://api.github.com/repos/softwaremill/reactive-kafka/milestones/1/labels","id":1273038,"number":1,"title":"0.8.0","description":"","creator":{"login":"kciesielski","id":1413553,"avatar_url":"https://avatars.githubusercontent.com/u/1413553?v=3","gravatar_id":"","url":"https://api.github.com/users/kciesielski","html_url":"https://github.com/kciesielski","followers_url":"https://api.github.com/users/kciesielski/followers","following_url":"https://api.github.com/users/kciesielski/following{/other_user}","gists_url":"https://api.github.com/users/kciesielski/gists{/gist_id}","starred_url":"https://api.github.com/users/kciesielski/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kciesielski/subscriptions","organizations_url":"https://api.github.com/users/kciesielski/orgs","repos_url":"https://api.github.com/users/kciesielski/repos","events_url":"https://api.github.com/users/kciesielski/events{/privacy}","received_events_url":"https://api.github.com/users/kciesielski/received_events","type":"User","site_admin":false},"open_issues":3,"closed_issues":4,"state":"open","created_at":"2015-08-26T08:46:13Z","updated_at":"2015-08-26T08:49:35Z","due_on":null,"closed_at":null},"comments":5,"created_at":"2015-08-21T10:37:23Z","updated_at":"2015-08-26T11:34:39Z","closed_at":"2015-08-24T11:03:08Z","body":"```\r\n  private def processElement(element: T) = {\r\n    producer.send(props.encoder.toBytes(element), props.partitionizer(element))\r\n  }\r\n```\r\nI here the encoder may cause an error,and I don't want the actor subscriber to fail.I can't find anyway to handle it.\r\n\r\nthe akka doc said :\r\n```\r\nActorPublisher source and ActorSubscriber sink components do not honour the supervision strategy attribute yet.\r\n```\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/comments/134957387","html_url":"https://github.com/softwaremill/reactive-kafka/issues/29#issuecomment-134957387","issue_url":"https://api.github.com/repos/softwaremill/reactive-kafka/issues/29","id":134957387,"user":{"login":"hepin1989","id":501740,"avatar_url":"https://avatars.githubusercontent.com/u/501740?v=3","gravatar_id":"","url":"https://api.github.com/users/hepin1989","html_url":"https://github.com/hepin1989","followers_url":"https://api.github.com/users/hepin1989/followers","following_url":"https://api.github.com/users/hepin1989/following{/other_user}","gists_url":"https://api.github.com/users/hepin1989/gists{/gist_id}","starred_url":"https://api.github.com/users/hepin1989/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/hepin1989/subscriptions","organizations_url":"https://api.github.com/users/hepin1989/orgs","repos_url":"https://api.github.com/users/hepin1989/repos","events_url":"https://api.github.com/users/hepin1989/events{/privacy}","received_events_url":"https://api.github.com/users/hepin1989/received_events","type":"User","site_admin":false},"created_at":"2015-08-26T11:34:39Z","updated_at":"2015-08-26T11:34:39Z","body":"@kciesielski once I realized that I could return the props ,I just attach it as a child actor and the override the supervison strategy.\r\nbut from the doc,said that:\r\n>ZipWith, FlexiMerge, FlexiRoute junction, ActorPublisher source and ActorSubscriber sink components do not honour the supervision strategy attribute yet.\r\n\r\nwill the solution you described here works?\r\n"}}