class_docstr: Interface defining information available at process time
class_docstr_tok: ["Interface","defining","information","available","at","process","time"]
docstr: Publishes message to topic_name by first serializing the message using serde_class_name serde
  The message will have properties specified if any
  
  The available options for message_conf:
  
    properties,
    partition_key,
    ordering_key,
    sequence_id,
    replication_clusters,
    disable_replication,
    event_timestamp
docstr_tok: ["Publishes","message","to","topic_name","by","first","serializing","the","message","using","serde_class_name","serde","The","message","will","have","properties","specified","if","any","The","available","options","for","message_conf",":","properties",",","partition_key",",","ordering_key",",","sequence_id",",","replication_clusters",",","disable_replication",",","event_timestamp"]
code: def publish(
      self,
      topic_name,
      message,
      serde_class_name="serde.IdentitySerDe",
      properties=None,
      compression_type=None,
      callback=None,
      message_conf=None,
  ):
      """Publishes message to topic_name by first serializing the message using serde_class_name serde
      The message will have properties specified if any
  
      The available options for message_conf:
  
        properties,
        partition_key,
        ordering_key,
        sequence_id,
        replication_clusters,
        disable_replication,
        event_timestamp
  
      """
      pass
  
imports: from abc import abstractmethod
label_desc: Use image node_id 19 for calling the Context obj's underlying member method code with example usage: obj.publish(topic_name, message, serde_class_name, properties, compression_type, callback, message_conf) without return types