Tags: deeplon/kafka-go
Tags
Add Transactionalmessage interface for request routing (segmentio#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 (segmentio#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 segmentio#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. (segmentio#716) * Preserve message order across batches. Co-authored-by: Michael Graf <mikegraf000@gmail.com>
Only refresh metadata on success (segmentio#672) (segmentio#673) * Only refresh metadata on success (segmentio#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. (segmentio#652) Fixes segmentio#651.
PreviousNext