Fixup producer failover tests to avoid consumer message count flap
check message counts via consumer.pending() (OffsetRequest)
instead of relying on consumer message iterator (FetchRequest)