Function TestDescribeGroupsInvalidAssignments

describegroups_test.go:260–310

(t *testing.T)

}

func TestDescribeGroupsInvalidAssignments(t *testing.T) {
	// Test the case where assignments are invalid but metadata is valid
	mockResp := &describegroups.Response{
		Groups: []describegroups.ResponseGroup{
			{
				ErrorCode:    0,
				GroupID:      "group-with-bad-assignments",
				GroupState:   "Stable",
				ProtocolType: "consumer",
				Members: []describegroups.ResponseGroupMember{
					{
						MemberID:   "member-1",
						ClientID:   "client-1",
						ClientHost: "/127.0.0.1",
						// Valid metadata
						MemberMetadata: []byte{0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00},
						// Invalid assignments - truncated
						MemberAssignment: []byte{0x00},
					},
				},
			},
		},
	}

	client := &Client{
		Transport: &mockRoundTripper{response: mockResp},
	}

	ctx := context.Background()
	resp, err := client.DescribeGroups(ctx, &DescribeGroupsRequest{
		Addr:     TCP("localhost:9092"),
		GroupIDs: []string{"group-with-bad-assignments"},
	})

	if err != nil {
		t.Fatalf("Unexpected error from DescribeGroups: %v", err)
	}

	// Verify we got the group back with an error
	if len(resp.Groups) != 1 {
		t.Fatalf("Expected 1 group, got %d", len(resp.Groups))
	}

	if resp.Groups[0].Error == nil {
		t.Error("Expected group to have an error for invalid assignments, got nil")
	}

	if len(resp.Groups[0].Members) != 0 {
		t.Errorf("Expected group to have 0 members due to error, got %d", len(resp.Groups[0].Members))
	}
}

func TestDescribeGroupsPartialMembersCleared(t *testing.T) {
	mockResp := &describegroups.Response{