v0.2.1

NATS:

• add default ack wait timeout, the lack of default value caused ACK timeout immediately

v0.2.0

• 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.

v0.1.2

Middlewares:

• fixed throttling middleware

Docs:

• added README
• added new example

Misc:

• added go modules support
• some code cleanups

v0.1.1

Kafka subscriber:

• changed default auto offset reset to "earliest"
• moved default serializer to main package

v0.1.0

added some http-to-kafka docs