package sarama import ( "testing" "time" ) var ( deleteAclsResponse = []byte{ 0, 0, 0, 100, 0, 0, 0, 1, 0, 0, // no error 255, 255, // no error message 0, 0, 0, 1, // 1 matching acl 0, 0, // no error 255, 255, // no error message 2, // resource type 0, 5, 't', 'o', 'p', 'i', 'c', 0, 9, 'p', 'r', 'i', 'n', 'c', 'i', 'p', 'a', 'l', 0, 4, 'h', 'o', 's', 't', 4, 3, } ) func TestDeleteAclsResponse(t *testing.T) { resp := &DeleteAclsResponse{ ThrottleTime: 100 * time.Millisecond, FilterResponses: []*FilterResponse{{ MatchingAcls: []*MatchingAcl{{ Resource: Resource{ResourceType: AclResourceTopic, ResourceName: "topic"}, Acl: Acl{Principal: "principal", Host: "host", Operation: AclOperationWrite, PermissionType: AclPermissionAllow}, }}, }}, } testResponse(t, "", resp, deleteAclsResponse) }