ThreeDotsLabs/watermill v0.2.0

on GitHub

• Added watermill.io docs. (#18)
• Added context.Context to the message. (#24)
• Replaced Kafka Pub/Sub implementation with Sarama (no cgo needed now!). (#22)
• Added Google Cloud Pub/Sub. (#10)
• Added NATS Streaming Pub/Sub. (#19)
• ...and more minor changes

Detailed changelog: https://threedots.tech/post/watermill-0-2/

Breaking changes and API cleanups:

• kafka.NewCustomPublisher is removed, please use NewPublisher instead.
• kafka.ConfluentConsumerConstructor is removed and no longer needed.
• kafka.SubscriberConfig.NoConsumerGroup is no longer needed. You can now just pass empty kafka.SubscriberConfig.ConsumerGroup.
• kafka.AutoOffsetReset is removed. Please use github.com/Shopify/sarama.Config.Consumer.Offsets.Initial passed to NewSubscriber overwriteSaramaConfig argument instead.
• kafka.ConsumersCount is removed and no longer needed.
• kafka.KafkaConfigOverwrite is removed and no longer needed. You can now pass sarama.Config to NewSubscriber and NewPublisher.
• kafka.NewConfluentSubscriber is removed. Please use kafka.NewSubscriber instead.
• kafka.NewCustomConfluentSubscriber is removed. Please use kafka.NewSubscriber instead.
• kafka.DefaultConfluentConsumerConstructor is removed and no longer needed.
• kafka.Marshaler and kafka.Unmarshaler interface was changed to compatible with Sarama API.