v1.3.4

Changelog

• b487293 feat: add message key to producer (#52)

v1.3.3

Changelog

• a866978 fix: metric name two underscore problem

v1.2.3

Changelog

• 97d648c chore(deps): bump github.com/segmentio/kafka-go from 0.4.39 to 0.4.42 (#42)

v1.2.2

Changelog

• 923724b feat: add exception related metrics via prometheus collector (#41)

v1.2.1

Changelog

• 481c750 feat: maxRetry gte

v1.2.0

Changelog

• 084afce feat: client id implementation for consumer and producer (#38)

v1.1.0

Changelog

• 3f36f11 feat: add client id for segmentio transport config (#36)
• dfb6107 feat: support producing as batches

v1.0.0

Changelog

• ba5af14 Update README.md
• 850a533 feat: add kafka producer close method for gracefully shutdown purpose
• 5fda6e5 feat: offset type constant values earliest, latest

v0.6.4

Changelog

• 850a533 feat: add kafka producer close method for gracefully shutdown purpose
• 5fda6e5 feat: offset type constant values earliest, latest
• cdde40f feat: add toStringOffset method to config
• 82cd590 feat: upgrade kafka-go version v0.4.39

v0.6.3

Changelog

• c4a46d4 Upgrades & Security fixes (#33)
• 1c06def feat: security fixes, downgrade kafka-go and update defaults