ThreeDotsLabs/watermill

can watermill kafka client support sarama.NewAsyncProducer() ? about 2 months ago

enhancement help wanted good first issue

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

[watermill-kafka] Add support for providing existing sarama.Client to kafka.Subscriber about 2 months ago

enhancement help wanted good first issue

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Is there any way to write clean up hook after max retries? about 2 months ago

enhancement help wanted good first issue

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

How to process a batch of received messages instead of a single piece? about 2 months ago

enhancement help wanted discussion needed

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Router closes publisher before message processing is done about 2 months ago

help wanted

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Watermill HTTP support http2 and chi-v5 2 months ago

help wanted good first issue

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Allow to select which errors are retryable in the Retry middleware 2 months ago

enhancement help wanted good first issue

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Better integration with opentracing 2 months ago

enhancement help wanted M

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

MySQL Binlog subscriber 2 months ago

enhancement help wanted M New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

PostgreSQL LISTEN/NOTIFY Subscriber 2 months ago

enhancement help wanted discussion needed M New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

[watermill-sql] Nacked message stays within one consumer 2 months ago

bug help wanted S

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Integration with go cloud development toolkit pubsub 2 months ago

enhancement help wanted M New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

MongoDB Pub/Sub 2 months ago

enhancement help wanted L New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Eventstore Pub/Sub 2 months ago

enhancement help wanted L New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Apache Pulsar Pub/Sub implementation 2 months ago

help wanted M New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

AWS Kinesis Pub/Sub implementation 2 months ago

help wanted New Pub/Sub

ThreeDotsLabs/watermill

8.9K

Building event-driven applications the easy way in Go.

Go

#cqrs#event-driven#event-sourcing#events#go#golang#kafka#nats#rabbitmq#reactive#sagas#stream-processing#watermill

Open Issues Need Help