docs: def get_kafka_producer(acks='all',
                         value_serializer=lambda v: json.dumps(v).encode('utf-8')):
      """
      Return a KafkaProducer that uses the SSLContext created with create_ssl_context.
      """
  
      producer = KafkaProducer(
          bootstrap_servers=get_kafka_brokers(),
          security_protocol='SSL',
          ssl_context=get_kafka_ssl_context(),
          value_serializer=value_serializer,
          acks=acks
      )
  
      return producer