Merge pull request #39504 from hashicorp/f-r/aws_kinesis_stream-tag-o…

…n-create

r/aws_kinesis_stream: Tag on create

.changelog/39504.txt

@@ -0,0 +1,3 @@
+```release-note:enhancement
+resource/aws_kinesis_stream: Tag on Create to support attribute-based access control (ABAC)
+```

internal/service/kinesis/generate.go

@@ -1,7 +1,7 @@
 // Copyright (c) HashiCorp, Inc.
 // SPDX-License-Identifier: MPL-2.0
 
-//go:generate go run ../../generate/tags/main.go -ListTags -ListTagsOp=ListTagsForStream -ListTagsInIDElem=StreamName -ServiceTagsSlice -TagOp=AddTagsToStream -TagOpBatchSize=10 -TagInCustomVal=updatedTags.IgnoreAWS().Map() -TagInIDElem=StreamName -UntagOp=RemoveTagsFromStream -UpdateTags -CreateTags
+//go:generate go run ../../generate/tags/main.go -ListTags -ListTagsOp=ListTagsForStream -ListTagsInIDElem=StreamName -ServiceTagsSlice -TagOp=AddTagsToStream -TagOpBatchSize=10 -TagInCustomVal=updatedTags.IgnoreAWS().Map() -TagInIDElem=StreamName -UntagOp=RemoveTagsFromStream -UpdateTags
 //go:generate go run ../../generate/servicepackage/main.go
 // ONLY generate directives and package declaration! Do not add anything else to this file.
 

internal/service/kinesis/stream.go

@@ -165,6 +165,10 @@ func resourceStreamCreate(ctx context.Context, d *schema.ResourceData, meta inte
 		input.ShardCount = aws.Int32(int32(d.Get("shard_count").(int)))
 	}
 
+	if tags := KeyValueTags(ctx, getTagsIn(ctx)).Map(); len(tags) > 0 {
+		input.Tags = tags
+	}
+
 	_, err := conn.CreateStream(ctx, input)
 
 	if err != nil {
@@ -240,10 +244,6 @@ func resourceStreamCreate(ctx context.Context, d *schema.ResourceData, meta inte
 		}
 	}
 
-	if err := createTags(ctx, conn, name, getTagsIn(ctx)); err != nil {
-		return sdkdiag.AppendErrorf(diags, "setting Kinesis Stream (%s) tags: %s", name, err)
-	}
-
 	return append(diags, resourceStreamRead(ctx, d, meta)...)
 }