feat(reader): allow consuming from multiple topics with a group (segm…

…entio#600)

added HighWaterMark to Message (segmentio#374)

Kafka Client FindCoordinator implementation (segmentio#596)

* Kafka client Find coordinator implementation

* Added retries to Find coordinator test

* Updated findcoordinator with indefinite wait function

* Refactored findcoordinator retry check into a function

* Increased coordinator wait period

* FindCoordinator updates for keeping the public API consistent

* Moved waiting for coordinator implementation to the test file

* makeError error already contains kafka.Error information

* Extra comment in test to re-trigger Snyk

* Response error should be nil even if kafka responds with an error code

Improve `reader` error messages

0.4: reduce memory footprint (segmentio#547)

fix zstd decoder leak (segmentio#543)

* fix zstd decoder leak

* fix tests

* fix panic

* fix tests (2)

* fix tests (3)

* fix tests (4)

* move ConnWaitGroup to testing package

* fix zstd codec

* Update compress/zstd/zstd.go

Co-authored-by: Nicholas Sun <olassun2@gmail.com>

* PR feedback

Co-authored-by: Nicholas Sun <olassun2@gmail.com>

Remove deprecated function (NewWriter) usages (segmentio#528)

0.4 broker resolver (segmentio#526)

* 0.4: kafka.BrokerResolver

* add kafka.Transport.Context

* inline network and address fields in conn type

Fix for panic when RequiredAcks is set to RequireNone (segmentio#504)

* Fix panic in async wait() method when RequiredAcks is None

When RequiredAcks is None, the producer does not wait for a
response from the broker, therefore the response is nil.
The async wait() method was not handling this case, leading
to a panic.

* Add regression test for RequiredAcks == RequireNone

This new test is required because all the other Writer tests use
NewWriter() to create Writers, which sets RequiredAcks to
RequireAll when 0 (None) was specified.

Fix consumer group timeout handling (segmentio#510)

PR segmentio#509 introduced a bug that could create infinite rebalance loops
when the Timeout is less than the RebalanceTimeout because the JoinGroup
call could timeout before the rebalance completes.