Change Url passing to KafkaEndpoint
This is in preparation for removing the need to close the connection to the
original set of urls.  With a KafkaEndpoint it will use the IP/port to uniquely
identify the connections.
Fix debug output
Change default connection move to broker index
No longer need to close down and reconnect after default
connection collection is cleared.  Identified by IP now.
Change factory to use endpoint instead of uri
Fixed tests to work with new endpoint.