segmentio / kafka-go Public

Add Transactionalmessage interface for request routing (#744)
* Add TransactionalMessage interface.

Add TransactionMessage interface so the Transport
automatically routes messages to Transaction Coordinators
if required.

Add Code of Conduct and Contribution Guidelines (#699)
* Add Code of Conduct and Contribution Guidelines

Add a full Code of Conduct and Code Contribution Guidelines document.
Provide description on how best to retrieve code, fork, checkout, and commit changes.

Fixes #688

* Update steps for git push

* Update based on PR comments

Removed several linkable sections in the Code of Conduct.
Update contributing to use kafka-go consistently.
Finished explaining how to replace the original version with forked version of the library.

* Update based on further feedback

* Adjust to follow the twilio-go code of contact

Preserve message order across batches. (#716)
* Preserve message order across batches.

Co-authored-by: Michael Graf <[email protected]>

Only refresh metadata on success (#672) (#673)
* Only refresh metadata on success (#672)

Implements changes discussed and agreed in GitHub issue.

* Second draft solution to issue 672

* Create unit test to detect issue 672

* Check for nil event in test 672

Cache version specific encoders/decoders. (#652)
Fixes #651.

automatically discover first/last offset in client fetch requests (#638)

update to v2.6.0

update isTimeout and isTemporary to properly unwrap errors (#616)
* update isTimeout and isTemporary to properly unwrap errors

* use interface instead

feat(reader): allow consuming from multiple topics with a group (#600)

added HighWaterMark to Message (#374)