Function waitForCoordinatorIndefinitely

findcoordinator_test.go:65–73

WaitForCoordinatorIndefinitely is a blocking call till a coordinator is found.

(ctx context.Context, c *Client, req *FindCoordinatorRequest)

// WaitForCoordinatorIndefinitely is a blocking call till a coordinator is found.
func waitForCoordinatorIndefinitely(ctx context.Context, c *Client, req *FindCoordinatorRequest) (*FindCoordinatorResponse, error) {
	resp, err := c.FindCoordinator(ctx, req)

	for shouldRetryfindingCoordinator(resp, err) && ctx.Err() == nil {
		time.Sleep(1 * time.Second)
		resp, err = c.FindCoordinator(ctx, req)
	}
	return resp, err
}

// Should retry looking for coordinator
// Returns true when the test Kafka broker is still setting up.