v1.0.1

• Allow Anything in mock Pipe expectations

v1.0.0

• Now does asynchronous processing using gorouties and channels for each processor.

v0.5.4

Updating offset correctly (#17)

v0.5.3

BROKEN!!! Use v0.5.4 instead!

• Fixed a data race in Kafka source metadata

v0.5.2

• Use atomic bool instead of RWMutex for the "running" flag

v0.5.1

• Protected the "running" flag with RWMutex

v0.5.0

• Adds the concept of source metadata on the Message

v0.4.1

• Fix concurrent map access in Kafka Source

v0.4.0

• Updated msales/pkg to version 2.*

v0.3.0

API Breaking Change!

• Adds better and more tests
• Redefines the Context to Pipe
• Adds the Message object to move messages around
• Adds context.Context to the message