Fix mapping

akvelon · Mar 13, 2024 · 6fccfe6 · 6fccfe6
1 parent 0a6bf97
commit 6fccfe6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Python/yaml/kafka_to_bigquery.yaml b/Python/yaml/kafka_to_bigquery.yaml
@@ -28,12 +28,12 @@ pipeline:
         language: python
         fields:
           message:
-            callable: "lambda row: row.payload.decode('utf-8')"
+            callable: "lambda row: str(row.payload.decode('utf-8'))"
 
   sink:
     type: WriteToBigQuery
     config:
-      table: project-id.dataset-id.tabe-id
+      table: project-id.dataset-id.table-id
       create_disposition: CREATE_IF_NEEDED
       write_disposition: WRITE_APPEND
     windowing: