诡异的鱼塘
珍爱生命 远离RocketMQ
GitHub
出现 fatal error: concurrent map iteration and map write错误 · Issue #1165 · apache/rocketmq-client-go
使用过程 err = mqConsumer.consumerIns.Subscribe(consumerTopic, consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { for i := range msgs...