Specify standard charset as UTF-8

Ulada Butsenka · Ulada Butsenka · commit 27c0588bc003 · 2026-02-18T12:02:56.000+01:00
diff --git a/v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java b/v2/pubsub-to-redis/src/main/java/com/google/cloud/teleport/v2/templates/PubSubToRedis.java
@@ -451,7 +451,7 @@ public void processElement(ProcessContext c) {
                     FailsafeElement<PubsubMessage, String> element = c.element();
                     c.output(
                         new PubsubMessage(
-                            element.getPayload().getBytes(),
+                            element.getPayload().getBytes(java.nio.charset.StandardCharsets.UTF_8),
                             element.getOriginalPayload().getAttributeMap(),
                             element.getOriginalPayload().getMessageId()));
                   }

Original file line number	Diff line number	Diff line change
`@@ -451,7 +451,7 @@ public void processElement(ProcessContext c) {`
`451`	`451`	`FailsafeElement<PubsubMessage, String> element = c.element();`
`452`	`452`	`c.output(`
`453`	`453`	`new PubsubMessage(`
`454`		`- element.getPayload().getBytes(),`
	`454`	`+ element.getPayload().getBytes(java.nio.charset.StandardCharsets.UTF_8),`
`455`	`455`	`element.getOriginalPayload().getAttributeMap(),`
`456`	`456`	`element.getOriginalPayload().getMessageId()));`
`457`	`457`	`}`