在Golang中使用Kafka进行消息路由，你需要使用一个支持Kafka的客户端库。一个流行的库是sarama。以下是一个简单的示例，展示了如何使用sarama库在Golang中设置Kafka生产者，并根据消息的主题进行路由。

首先，确保你已经安装了sarama库。如果没有，请运行以下命令安装：

go get github.com/Shopify/sarama

接下来，创建一个简单的Golang程序，用于发送和接收Kafka消息：

package mainimport ("fmt""log""os""os/signal""sync""github.com/Shopify/sarama")const (kafkaBrokers = "localhost:9092"topicA = "topicA"topicB = "topicB")func main() {config := sarama.NewConfig()config.Producer.RequiredAcks = sarama.WaitForAllconfig.Producer.Retry.Max = 5config.Producer.Return.Successes = trueproducer, err := sarama.NewSyncProducer([]string{kafkaBrokers}, config)if err != nil {log.Fatalf("Error creating producer: %v", err)}defer func() {if err := producer.Close(); err != nil {log.Fatalf("Error closing producer: %v", err)}}()consumer, err := sarama.NewConsumerGroup([]string{kafkaBrokers}, "my-group", config)if err != nil {log.Fatalf("Error creating consumer: %v", err)}defer func() {if err := consumer.Close(); err != nil {log.Fatalf("Error closing consumer: %v", err)}}()topicAHandler := func(msg *sarama.ConsumerMessage) error {fmt.Printf("Received message from topicA: %s\n", string(msg.Value))return nil}topicBHandler := func(msg *sarama.ConsumerMessage) error {fmt.Printf("Received message from topicB: %s\n", string(msg.Value))return nil}err = consumer.Consume(context.Background(), []string{topicA, topicB}, topicAHandler, topicBHandler)if err != nil {log.Fatalf("Error consuming messages: %v", err)}signals := make(chan os.Signal, 1)signal.Notify(signals, os.Interrupt)<-signals}

在这个示例中，我们创建了一个Kafka生产者，用于将消息发送到指定的主题（topicA或topicB）。我们还创建了一个消费者组，用于从这两个主题接收消息。根据接收到的消息的主题，我们调用相应的处理函数（topicAHandler或topicBHandler）。

请注意，这个示例仅用于演示目的。在实际应用中，你可能需要根据业务需求对消息路由进行更复杂的处理，例如使用消息队列、负载均衡器或其他中间件。