Function shouldRetryfindingCoordinator

findcoordinator_test.go:77–86

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

(resp *FindCoordinatorResponse, err error)

// Should retry looking for coordinator
// Returns true when the test Kafka broker is still setting up.
func shouldRetryfindingCoordinator(resp *FindCoordinatorResponse, err error) bool {
	brokerSetupIncomplete := err != nil &&
		strings.Contains(
			strings.ToLower(err.Error()),
			strings.ToLower("unexpected EOF"))
	coordinatorNotFound := resp != nil &&
		resp.Error != nil &&
		errors.Is(resp.Error, GroupCoordinatorNotAvailable)
	return brokerSetupIncomplete || coordinatorNotFound
}