{"action":"created","issue":{"url":"https://api.github.com/repos/sclasen/akka-kafka/issues/52","repository_url":"https://api.github.com/repos/sclasen/akka-kafka","labels_url":"https://api.github.com/repos/sclasen/akka-kafka/issues/52/labels{/name}","comments_url":"https://api.github.com/repos/sclasen/akka-kafka/issues/52/comments","events_url":"https://api.github.com/repos/sclasen/akka-kafka/issues/52/events","html_url":"https://github.com/sclasen/akka-kafka/issues/52","id":153859971,"number":52,"title":"Specifying multiple topic","user":{"login":"eugenemiretsky","id":1828811,"avatar_url":"https://avatars.githubusercontent.com/u/1828811?v=3","gravatar_id":"","url":"https://api.github.com/users/eugenemiretsky","html_url":"https://github.com/eugenemiretsky","followers_url":"https://api.github.com/users/eugenemiretsky/followers","following_url":"https://api.github.com/users/eugenemiretsky/following{/other_user}","gists_url":"https://api.github.com/users/eugenemiretsky/gists{/gist_id}","starred_url":"https://api.github.com/users/eugenemiretsky/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/eugenemiretsky/subscriptions","organizations_url":"https://api.github.com/users/eugenemiretsky/orgs","repos_url":"https://api.github.com/users/eugenemiretsky/repos","events_url":"https://api.github.com/users/eugenemiretsky/events{/privacy}","received_events_url":"https://api.github.com/users/eugenemiretsky/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2016-05-09T20:16:45Z","updated_at":"2016-05-09T20:37:16Z","closed_at":null,"body":"Would it make sense to allow passing a Map of <Topic, Stream #> to create a consumer for multiple topics? \r\nIt's currently possible to do that by passing a TopicFilter, but it would be nice to have controlle over the number of streams for each topic"},"comment":{"url":"https://api.github.com/repos/sclasen/akka-kafka/issues/comments/217981893","html_url":"https://github.com/sclasen/akka-kafka/issues/52#issuecomment-217981893","issue_url":"https://api.github.com/repos/sclasen/akka-kafka/issues/52","id":217981893,"user":{"login":"sclasen","id":523338,"avatar_url":"https://avatars.githubusercontent.com/u/523338?v=3","gravatar_id":"","url":"https://api.github.com/users/sclasen","html_url":"https://github.com/sclasen","followers_url":"https://api.github.com/users/sclasen/followers","following_url":"https://api.github.com/users/sclasen/following{/other_user}","gists_url":"https://api.github.com/users/sclasen/gists{/gist_id}","starred_url":"https://api.github.com/users/sclasen/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sclasen/subscriptions","organizations_url":"https://api.github.com/users/sclasen/orgs","repos_url":"https://api.github.com/users/sclasen/repos","events_url":"https://api.github.com/users/sclasen/events{/privacy}","received_events_url":"https://api.github.com/users/sclasen/received_events","type":"User","site_admin":false},"created_at":"2016-05-09T20:37:16Z","updated_at":"2016-05-09T20:37:16Z","body":"pretty easy in userspace, if I understand your approach?\r\n\r\n```\r\nval props : AkkaConsumerProps[K,V] = ???\r\nval topicStreams : Map[String,Int] = ???\r\n\r\nval consumers = topicStreams.map{\r\n  case (t, s) => \r\n      val prop = props.copy(topicFilterOrTopic = Right(t), streams=s)\r\n      val consumer = new AkkaConsumer(prop)\r\n      (t, consumer)\r\n}\r\n```\r\n\r\nhappy to take a PR that makes this easier if you have something in mind.\r\n\r\nCheers!"}}