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 :)