How can multiple subscribers on a topic only consume once about go-micro HOT 2 CLOSED

Did you set SubscribeOptions's option "Queue"? If so, try unset it.

type SubscribeOptions struct {
	// AutoAck defaults to true. When a handler returns
	// with a nil error the message is acked.
	AutoAck bool
	// Subscribers with the same queue name
	// will create a shared subscription where each
	// receives a subset of messages.
	Queue string

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

http broker will set version as broadcastVersion if SubscribeOptions's Queue was set.

// check for queue group or broadcast queue
version := options.Queue
if len(version) == 0 {
    version = broadcastVersion
}

broker will broadcast message to all subscriber if version was set as broadcastVersion.

        switch service.Version {
	// broadcast version means broadcast to all nodes
	case broadcastVersion:
		var success bool

		// publish to all nodes
		for _, node := range nodes {
			// publish async
			if err := pub(node, topic, b); err == nil {
				success = true
			}
		}

		// save if it failed to publish at least once
		if !success {
			h.saveMessage(topic, b)
		}
	default:
		// select node to publish to
		node := nodes[rand.Int()%len(nodes)]

		// publish async to one node
		if err := pub(node, topic, b); err != nil {
			// if failed save it
			h.saveMessage(topic, b)
		}
	}

from go-micro.

Did you set SubscribeOptions's option "Queue"? If so, try unset it.

type SubscribeOptions struct {
	// AutoAck defaults to true. When a handler returns
	// with a nil error the message is acked.
	AutoAck bool
	// Subscribers with the same queue name
	// will create a shared subscription where each
	// receives a subset of messages.
	Queue string

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

http broker will set version as broadcastVersion if SubscribeOptions's Queue was set.

// check for queue group or broadcast queue
version := options.Queue
if len(version) == 0 {
    version = broadcastVersion
}

broker will broadcast message to all subscriber if version was set as broadcastVersion.

        switch service.Version {
	// broadcast version means broadcast to all nodes
	case broadcastVersion:
		var success bool

		// publish to all nodes
		for _, node := range nodes {
			// publish async
			if err := pub(node, topic, b); err == nil {
				success = true
			}
		}

		// save if it failed to publish at least once
		if !success {
			h.saveMessage(topic, b)
		}
	default:
		// select node to publish to
		node := nodes[rand.Int()%len(nodes)]

		// publish async to one node
		if err := pub(node, topic, b); err != nil {
			// if failed save it
			h.saveMessage(topic, b)
		}
	}

ok，thanks

from go-micro.