mirror of https://github.com/apache/kafka.git
This patch adds the logic for coordinating the invocation of the `ConsumerRebalanceListener` callback invocations between the background thread (in `MembershipManagerImpl`) and the application thread (`AsyncKafkaConsumer`) and back again. It allowed us to enable more tests from `PlaintextConsumerTest` to exercise the code herein. Reviewers: David Jacot <djacot@confluent.io> |
||
---|---|---|
.. | ||
.scalafmt.conf | ||
checkstyle.xml | ||
import-control-core.xml | ||
import-control-jmh-benchmarks.xml | ||
import-control-metadata.xml | ||
import-control-server-common.xml | ||
import-control-server.xml | ||
import-control-storage.xml | ||
import-control.xml | ||
java.header | ||
suppressions.xml |