go-queue

go-queue copied to clipboard

go-zero v1.3.5 used go-queue v1.1.6 happen error, and v1.3.2 not

xs0910

比如kafka服务器挂掉的情形，我们调用者有办法获取到对应的错误吗？因为生产者客户端的缓冲机制，Push方法并没有真正的推送消息，所以拿不到错误，这点可以理解；但是在执行缓冲的Flush方法中，推送出错时似乎也只是打印了一下日志，并没有通过任何方式将错误传出来？所以目前kq客户端的调用者是不是完全没办法获取到Flush中的错误状态？以及后续是不是可以考虑增加一个eventBus之类的对象，以便我们调用者挂上监听获取kq的错误状态？谢谢

chenkaiwei

dq example 疑问

1

NewProducer 方法里面要求 Endpoint 必须大于 2 且 Endpoints 必须是多个不同的实例，那是不是需要一个 beanstalkd 集群呢？ ``` func NewProducer(beanstalks []Beanstalk) Producer { if len(beanstalks) < minWrittenNodes { log.Fatalf("nodes must be equal or greater than %d", minWrittenNodes)...

withseid

The `github.com/streadway/amqp` module is no longer actively maintained. The new module is now maintained by the RabbitMQ core team under a different package name.

Juneezee

sgilson

kq下多Processors位移提交的问题

6

感谢对`kafka-go`进行服务化封装，的确用起来更简单了！ 我对消费代码有个疑惑，望解答： ``` for i := 0; i < q.c.Processors; i++ { q.consumerRoutines.Run(func() { for msg := range q.channel { if err := q.consumeOne(string(msg.Key), string(msg.Value)); err != nil { logx.Errorf("Error...

wanzirong

customized kafka message key

2

不太理解为什么不允许自定义的Key， 这对于某些必须保证消息有序性的场景来说非常不友好。 建议支持自定义的Key

Lichmaker

kq如何订阅多个主题

3

conf.MustLoad("config.json", &c)只能配置一个，要订阅多个难道只有定义多个配置文件？

erosiners

"kafka.NewWriter(config WriterConfig) *Writer " will be removed in kafka-go's version 1.0.

M4n5ter

lxxwilliam