relateiq/storm-kafka-0.8-plus — pull request #1 by rbpark (2014-05-20 23:59:46+00:00)
Title: Changed logging level to DEBUG. Reduces the per partition fetch logging.

Changed System.nano to System.currentTimeMillis. Since there was a conversion from nano to millisec, there was no need to do a more expensive operation.
Removed pre-counting of messages. For large messages, this could result in fetching multiple pages if the buffer is large. Probably shouldn't iterate the message buffer twice.

@adilaijaz