v1.1.1

Merge pull request #3 from gocollection/dev

Dev

Middleware and Interceptor

Middleware and Interceptor construct added similar to before and after advice of AOP

• Middleware - multiple middleware can be passed in consumer param to pre process messages before passing them to the topic handler
• Interceptor - interceptor lifecycle is available around the message handler i.e. before the message handling and after it. Multiple interceptor can be used which will intercept the message in layered fashion. Refer to godoc for more details and example.

Patch to limit the consumer session retry

• while starting a consumer session, it can cause a repeated error,
  patch restrict retries in such cases to 5 attempt with linear backoff
• A successful setup and clean up will reset the retry counter
• version support comments

Kafka abstraction for Consumer and Producer APIs

An easy abstraction to create Consumer and Producer workflow to a kafka cluster.

New Feature-

• Generic PubSub API, implementable by multiple PubSub frameworks. Kafka implementation added
• Create a Kafka Consumer, APIs to start and gracefully stop the consumer process
• Create a Kafka Producer, APIs to publish single/bulk messages in Sync and Async
• Fail safety and Leaks taken care of