Fix debezium port type, fix gemini post processor fn

Author: Amar3tto

sdks/python/apache_beam/examples/inference/gemini_text_classification.py

@@ -67,8 +67,18 @@ def parse_known_args(argv):
 
 class PostProcessor(beam.DoFn):
   def process(self, element: PredictionResult) -> Iterable[str]:
-    yield "Input: " + str(element.example) + " Output: " + str(
-        element.inference[1][0].content.parts[0].text)
+
+    inference = getattr(element, "inference", None)
+
+    if hasattr(inference[1], "content"):
+      yield inference[1].content.parts[0].text
+      return
+
+    if isinstance(inference[1], (tuple, list)) and len(inference) > 1:
+      yield "Input: " + str(element.example) + " Output: " + str(
+          inference[1][0].content.parts[0].text)
+    else:
+      yield "Can't decode inference for element: " + str(element.example)
 
 
 def run(

sdks/python/apache_beam/io/debezium.py

@@ -155,7 +155,7 @@ def __init__(
         username=username,
         password=password,
         host=host,
-        port=port,
+        port=str(port),
         max_number_of_records=max_number_of_records,
         connection_properties=connection_properties)
     self.expansion_service = expansion_service or default_io_expansion_service()