Add missing automated tests

[awr]

Consumer:

• do not lose message when blocked
• querying should move to the next offset automatically
• cancellation interrupts consumption
• coordinator state changes are managed correctly (when heartbeating, etc)
• when in the middle of processing a message and changing state, resolution for current position is satisfied

Assignment:

• only assigned partitions are read from
• if more members are subscribed than partitions, additional members gracefully exit (and do not cause excessive chatter)
• if same cardinality, one member is assigned to one partition
• if more partitions than members, all partitions are still assigned (as evenly as possible)
• works with 1 or many subscriptions
• extensible to a priority based assignment

Management / monitoring:

• can list topics
• can list consumer groups and offsets
• throughput telemetry numbers lie in correct range

[awr]

Also add:

• check for max number of elements of any given array (each stored in a static variable on the appropriate response type -- with bytes themselves being part of the connection configuration)