code: def _send_message_to_topic(self, topic, message):
          
          message_result = self.producer.send(topic, message)
          self.check_for_message_exception(message_result)
          return message_result
docs: Send a message to a Kafka topic.
  
          Parameters
          ----------
          topic : str
              The kafka topic where the message should be sent to.
          message : FranzEvent
              The message to be sent.
  
          Raises
          ------
          franz.InvalidMessage