Issues

• [watermill-sql] A missed ack deadline deletes the unprocessed rows of the batch (PostgreSQLQueueOffsetsAdapter)

  ThreeDotsLabs/watermill#700 · Filter by author thumbnail opened on Oct 2, 2026

• Router.Close() blocks for the full CloseTimeout when handlers were registered but the router was never (fully) run

  bug
  ThreeDotsLabs/watermill#697 · Filter by author markgoddard opened on Sep 18, 2026
  2

• [watermill-amqp] Data race on ConnectionWrapper.connected between IsConnected() and handleConnectionClose()

  ThreeDotsLabs/watermill#693 · Filter by author gamunu opened on Jul 29, 2026
  2

• Another gochannel pubsub question

  bug
  ThreeDotsLabs/watermill#692 · Filter by author Excpt0r opened on Jun 30, 2026
  1

• NATS Jetstream silently fails too fast

  bug
  ThreeDotsLabs/watermill#676 · Filter by author Jakob-Kaae opened on Apr 22, 2026

• Messages duplication issue

  ThreeDotsLabs/watermill#671 · Filter by author MadanaGopalD opened on Mar 17, 2026

• Logger severity setup not compatible with GCP logger

  bug
  ThreeDotsLabs/watermill#666 · Filter by author mdmourao opened on Jan 27, 2026

• SNS Subscription attributes that might change between version of the app causes startup failure

  bug
  ThreeDotsLabs/watermill#646 · Filter by author barp opened on Jan 10, 2026

• Feature Request: Support gRPC Pub/Sub

  enhancement
  ThreeDotsLabs/watermill#642 · Filter by author Cluas opened on Dec 5, 2025

• [watermill-redisstream] proto.RedisError NOGROUP No such key

  ThreeDotsLabs/watermill#641 · Filter by author egorsmkv opened on Nov 25, 2025
  4

• Interaction of ack timeout, retry middleware, and poison queue causes failures to write to poison queue.

  bug
  ThreeDotsLabs/watermill#636 · Filter by author Zach-Johnson opened on Nov 17, 2025

• [watermill-kafka] Context value added during unmarshal missing

  ThreeDotsLabs/watermill#633 · Filter by author mike-gurney opened on Nov 4, 2025

• TransparentUrlResolver always fails with DoNotCreateQueueIfNotExists set to true

  bug
  ThreeDotsLabs/watermill#632 · Filter by author JanKaczmarski opened on Oct 28, 2025

• Deduplication middleware backed by Redis

  enhancement
  ThreeDotsLabs/watermill#626 · Filter by author denpeshkov opened on Oct 10, 2025
  1

• Allow Middleware to know which handler will process or which topic the message came from

  enhancement
  ThreeDotsLabs/watermill#625 · Filter by author DrBlury opened on Oct 9, 2025

• Split producing topic in case of business error

  enhancement
  ThreeDotsLabs/watermill#622 · Filter by author DrBlury opened on Sep 26, 2025
  1

• [watermill-nats] wrongly assuming nats ackwait timeout begins when handler function is called

  bug
  ThreeDotsLabs/watermill#609 · Filter by author Guillembonet opened on Aug 28, 2025
  5

• librdkafka implementation

  enhancement
  ThreeDotsLabs/watermill#588 · Filter by author alex-kozin opened on Jul 30, 2025
  1

• How to batch consume messages

  enhancement
  ThreeDotsLabs/watermill#586 · Filter by author boringplay opened on Jul 30, 2025
  1

• can watermill kafka client support sarama.NewAsyncProducer() ?

  enhancementgood first issuehelp wanted
  ThreeDotsLabs/watermill#583 · Filter by author Jaylenwa opened on Jul 4, 2025
  6

• metrics support opentelemetry

  enhancement
  ThreeDotsLabs/watermill#574 · Filter by author ahkui opened on May 26, 2025

• Pub/Sub suport for Pocketbase

  enhancementNew Pub/Sub
  ThreeDotsLabs/watermill#572 · Filter by author eugeis opened on May 22, 2025
  2

• Some Watermill internal tests are written with null payloads

  ThreeDotsLabs/watermill#565 · Filter by author dkotik opened on May 15, 2025
  3

• [watermill-amqp] Implement Worker Pool for Concurrent Message Processing

  enhancement
  ThreeDotsLabs/watermill#558 · Filter by author UmutComlekci opened on Apr 29, 2025

• MQTT PubSub Implementation

  enhancementNew Pub/Sub
  ThreeDotsLabs/watermill#557 · Filter by author paulmarshall opened on Apr 23, 2025
  3