Open
Description
Should we consider using read next w/ timeout? What about when it reaches end of topic? Does the listener just sit and wait for data on the topic to come in?
This is fine for the 1st pass but I think we may want to look into a combination of readNext(int, TimeUnit) + hasMessageAvailable (or something) to avoid the blocking. It does not feel efficient. That being said, this can be a "duly noted" comment and we can noodle on it a bit and handle in later PR. Just capturing my thoughts.
Originally posted by @onobc in #342 (comment)