Specifying multiple topic

[eugenemiretsky]

Would it make sense to allow passing a Map of <Topic, Stream #> to create a consumer for multiple topics?
It'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

[sclasen]

pretty easy in userspace, if I understand your approach?

val props : AkkaConsumerProps[K,V] = ???
val topicStreams : Map[String,Int] = ???

val consumers = topicStreams.map{
  case (t, s) => 
      val prop = props.copy(topicFilterOrTopic = Right(t), streams=s)
      val consumer = new AkkaConsumer(prop)
      (t, consumer)
}

happy to take a PR that makes this easier if you have something in mind.

Cheers!