在使用事务性生产者发送消息时，需要指定事务ID，并在事务中发送消息到多个主题。如果在事务期间失败或其中一个主题出现错误，整个事务将被回滚。下面是示例代码：

// 初始化事务ID和 Kafka 生产者
val txID = UUID.randomUUID().toString()
val producer = new KafkaProducer[String, String](props)

try {
  // 开启事务
  producer.initTransactions()
  producer.beginTransaction()

  // 发送消息到 topic1
  val record1 = new ProducerRecord[String, String]("topic1", "key1", "value1")
  producer.send(record1)

  // 发送消息到 topic2
  val record2 = new ProducerRecord[String, String]("topic2", "key2", "value2")
  producer.send(record2)

  // 提交事务
  producer.commitTransaction()
} catch {
  case ex: Throwable => 
    // 回滚事务
    producer.abortTransaction()
} finally {
  producer.close()
}