Turns out we need that monitoring thread
Make sure we really ignore partial messages. Think this may be the source of offset corruption