Issues

• kafka目前不支持4.0版本

  zeromicro/go-queue#90 · Filter by author kingsh2012 opened on Jul 14, 2025
  3

• 计划支持mqtt 吗

  zeromicro/go-queue#89 · Filter by author maomao94 opened on Jun 17, 2025

• 应该支持设置 kafka reader 的更多参数

  zeromicro/go-queue#87 · Filter by author BubbleGarten2 opened on May 15, 2025

• 代码当中 kafkaQueue 结构体的 Stop 函数为啥把 logx 也 Close 了，全局的 logx 也 Close 了，把之前设置好的 logx 也变成输出控制台了

  zeromicro/go-queue#86 · Filter by author pwm1992 opened on Apr 29, 2025

• 写不进去kafka但是可以创建topic

  zeromicro/go-queue#83 · Filter by author caoshitong369 opened on Feb 6, 2025

• dq 的 consumerCluster 需要提供 Close 方法

  zeromicro/go-queue#81 · Filter by author marsmay opened on Dec 26, 2024

• dq 的 producerCluster 在使用中偶尔触发 runtime error: index out of range

  zeromicro/go-queue#80 · Filter by author marsmay opened on Dec 26, 2024

• kq能否支持Message Header

  zeromicro/go-queue#79 · Filter by author ryanreadbooks opened on Oct 16, 2024

• rabbitmq 消息手动应答与死信队列

  zeromicro/go-queue#74 · Filter by author a289459798 opened on Aug 9, 2024
  2

• go-queue 有计划支持pulsar消息队列吗？

  zeromicro/go-queue#71 · Filter by author guonaihong opened on Jul 16, 2024
  4

• 这个介绍也写的太寒酸了点吧

  zeromicro/go-queue#67 · Filter by author Vallenbo opened on Jun 2, 2024
  

• kq.KqConf.Consumers 感觉没什么意义啊

  zeromicro/go-queue#49 · Filter by author welllog opened on Jul 17, 2023
  6

• Support SASL/SCRAM authentication method

  zeromicro/go-queue#46 · Filter by author ISADBA opened on Jul 10, 2023
  1

• 为什么要将收到的消息转换为string

  zeromicro/go-queue#45 · Filter by author Dong148 opened on Jul 7, 2023
  2

• RabbitListener can not Manual ack calls are supported

  zeromicro/go-queue#44 · Filter by author maringpcoder opened on Jul 4, 2023

• kq how to with SASL ？

  zeromicro/go-queue#42 · Filter by author trancer-nature opened on Apr 21, 2023

• push.close() 后程序退出丢失消息

  zeromicro/go-queue#36 · Filter by author Meppo opened on Nov 1, 2022
  1

• bug: go-queue v1.1.6 an error occurred [NotEnoughReplicas]

  zeromicro/go-queue#32 · Filter by author xs0910 opened on Aug 4, 2022

• kq的报错机制似乎并不完善？

  zeromicro/go-queue#31 · Filter by author chenkaiwei opened on Jul 25, 2022

• dq example 疑问

  zeromicro/go-queue#30 · Filter by author withseid opened on Jun 22, 2022
  1

• kq下多Processors位移提交的问题

  zeromicro/go-queue#28 · Filter by author wanzirong opened on Jun 13, 2022
  6

• customized kafka message key

  zeromicro/go-queue#25 · Filter by author Lichmaker opened on Apr 20, 2022
  2

• kq如何订阅多个主题

  zeromicro/go-queue#24 · Filter by author erosiners opened on Mar 22, 2022
  3

• could kq support SASL to use third-service like alibaba cloud?

  zeromicro/go-queue#21 · Filter by author lxxwilliam opened on Jan 13, 2022

• RabbitMQ与RocketMQ

  zeromicro/go-queue#20 · Filter by author shuqingzai opened on Dec 20, 2021