support saslAuthenticate v0 in protocol package (segmentio#869)

sett ServerName on tls.Config even when InsecureSkipVeriy is true (se…

…gmentio#860)

This behavior also matches the old dialer behavior.

Add CreateAcls Admin API support (segmentio#839)

This adds a CreateACLs method to the kafka Client
to supports the CreateAcls Admin API.

Signed-off-by: Guillaume Fillon <guillaume.fillon@auth0.com>

Fix offset when a batch ends with compacted records

Saves the lastOffset and jumps past it when compacted
records are detected at the end of a batch.

- Adds a test for batches that end with compacted
records
- Adds a test for batches truncated due to MaxBytes


Co-authored-by: iddqdeika <iddqdeika@gmail.com>

Do a final commit on end consumer group generation for immediate comm…

…its (segmentio#715)

* Do a final commit on end consumer group generation for immediate commits

* add test for final commit on generation end

Co-authored-by: rhansen2 <rob.hansen@sendgrid.com>

Revert "Nettest fix (segmentio#788)" (segmentio#824)

This reverts commit 2e02f37.

SASL Mechanism: AWS MSK IAM (making requested edits) (segmentio#798)

Co-authored-by: Achille <achille.roussel@gmail.com>
Co-authored-by: Christian Maher <maher.cs@gmail.com>

Nettest fix (segmentio#788)

* don't skip messages when offset == highwatermark

Allow Writer to automatically create topics. (segmentio#775)

* set AutoCreateTopic when requesting metadata in Writer

if a metadata request is made with auto create topic set,
we now make a metadata request to trigger the topic creation
if the topic is not already in the cache and update the cache
after the request is made.