Skip to content

v0.2.0

Pre-release
Pre-release
Compare
Choose a tag to compare
@roblaszczak roblaszczak released this 18 Dec 13:15
· 314 commits to master since this release
  • 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.