code: def write_to_kafka(env):
      type_info = Types.ROW([Types.INT(), Types.STRING()])
      ds = env.from_collection(
          [
              (1, "hi"),
              (2, "hello"),
              (3, "hi"),
              (4, "hello"),
              (5, "hi"),
              (6, "hello"),
              (6, "hello"),
          ],
          type_info=type_info,
      )
  
      serialization_schema = CsvRowSerializationSchema.Builder(
          type_info
      ).build()
      kafka_producer = FlinkKafkaProducer(
          topic="test_csv_topic",
          serialization_schema=serialization_schema,
          producer_config={
              "bootstrap.servers": "localhost:9092",
              "group.id": "test_group",
          },
      )
  
      # note that the output type of ds must be RowTypeInfo
      ds.add_sink(kafka_producer)
      env.execute()
  
imports: import logging
  import sys
  from pyflink.common import Types
  from pyflink.datastream import StreamExecutionEnvironment
  from pyflink.datastream.connectors.kafka import FlinkKafkaProducer, FlinkKafkaConsumer
  from pyflink.datastream.formats.csv import CsvRowSerializationSchema, CsvRowDeserializationSchema
label_desc: Use image node_id 1 for calling a global function with example usage: write_to_kafka(env) without return types