Scott Clasen

No idea, can you try maven central and see if the same thing happens? What error do you see?

Are you perhaps using a different version of akka at runtime then the project was built with?

So, since this library was written before both kafka 0.9 and akka-streams 1.0 it looks the way it does. If I were going to re-write an akka-kafka client these days,...

Maybe this is already there? https://github.com/akka/reactive-kafka

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) =>...

You only need provide an `ActorRef` to any of the Consumers in this library. They can be backed by a standard actor or any of the existing akka routers or...

seems legit, want to do a PR?

When you commit every 10 milliseconds you are writing to zookeeper every 10 milliseconds. Your commit interval should be much, much larger. try 10 seconds?

and @pocman sorry for the huge lag, gmail started putting my github notifications in spam.

@coreyauger can you set the log level to DEBUG and send me the output?