在Golang中使用Kafka实现消息广播，你需要使用一个支持发布-订阅模式的Kafka客户端库。一个流行的库是confluentinc/confluent-kafka-go。以下是一个简单的示例，展示了如何使用这个库实现消息广播：
confluentinc/confluent-kafka-go库：go get github.com/confluentinc/confluent-kafka-go/kafka main.go的文件，并编写以下代码：package main import ( "fmt" "github.com/confluentinc/confluent-kafka-go/kafka" ) func main() { // Kafka配置 conf := kafka.ConfigMap{ "bootstrap.servers": "localhost:9092", "group.id": "my-group", "auto.offset.reset": "earliest", } // 创建一个新的消费者 c, err := kafka.NewConsumer(&conf) if err != nil { fmt.Printf("Failed to create consumer: %s\n", err) return } defer c.Close() // 订阅一个或多个主题 err = c.SubscribeTopics([]string{"my-topic"}, nil) if err != nil { fmt.Printf("Failed to subscribe to topics: %s\n", err) return } for { // 读取消息 msg, err := c.ReadMessage(-1) if err != nil { fmt.Printf("Failed to read message: %s\n", err) continue } // 打印消息内容 fmt.Printf("Received message: key=%s, value=%s, topic=%s, partition=%d, offset=%d\n", string(msg.Key), string(msg.Value), msg.Topic, msg.Partition, msg.Offset) // 广播消息到所有订阅的主题 for _, topic := range c.Subscriptions() { err = c.Produce(&kafka.Message{ TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny}, Value: msg.Value, }, nil) if err != nil { fmt.Printf("Failed to produce message to topic %s: %s\n", topic, err) } } } } 在这个示例中，我们创建了一个Kafka消费者，订阅了名为my-topic的主题。然后，我们在一个无限循环中读取消息，并将消息广播到所有订阅的主题。
请注意，你需要根据你的Kafka集群的配置修改bootstrap.servers和group.id。此外，确保你的Kafka集群正在运行并且可以从你的应用程序访问。
