docs: def get_kafka_consumer(topic=None,
                         value_deserializer=lambda v: json.loads(v.decode('utf-8'))):
      """
      Return a KafkaConsumer that uses the SSLContext created with create_ssl_context.
      """
  
      # Create the KafkaConsumer connected to the specified brokers. Use the
      # SSLContext that is created with create_ssl_context.
      consumer = KafkaConsumer(
          topic,
          bootstrap_servers=get_kafka_brokers(),
          security_protocol='SSL',
          ssl_context=get_kafka_ssl_context(),
          value_deserializer=value_deserializer
      )
  
      return consumer