Corey Auger

adding this as a ref http://mail-archives.apache.org/mod_mbox/kafka-users/201408.mbox/%3CCACim9RkJ6+6jJKzP3UQKQPbsOUsboifBoySpOYPm=2RPp9XUcw@mail.gmail.com%3E ``` > > If you want to restart the consumer in handling the timeout exception, > then > > you should probably just increasing...

Since timeout and auto commit are required for the HighLevel Consumer to work.. would it be best to append these arguments when the actor is creating the config? That way...

Updated https://github.com/coreyauger/akka-kafka/blob/master/src/main/scala/com/sclasen/akka/kafka/AkkaHighLevelConsumer.scala

Sounds good :)

This looks rad @SeanCheatham !! Nice work!

I am receiving this error as well. ``` [error] scala.ScalaReflectionException: type T is not a class [error] at scala.reflect.api.Symbols$SymbolApi$class.asClass(Symbols.scala:275) [error] at scala.reflect.internal.Symbols$SymbolContextApiImpl.asClass(Symbols.scala:84) [error] at upickle.Macros$.picklerFor(Macros.scala:75) [error] at upickle.Macros$.macroRImpl(Macros.scala:35) [error] upickle.read[T](d)...

I would be interested in helping with this as well :)

Thanks for reporting this.. I will try to find time in the next while to correct the demo project... or if you feel like submitting a PR that would be...

Can you be more specific? What part of the api are you referring to?