Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Rebalance: filter messages of revoked partitions #946

Merged
merged 2 commits into from Oct 30, 2019
Merged

Rebalance: filter messages of revoked partitions #946

merged 2 commits into from Oct 30, 2019

Commits on Oct 23, 2019

  1. Rebalance: filter messages of revoked partitions 

    As the `RebalanceSpec` test in akka#865 shows, the consumer stage's
buffer continues to emit messages of revoked partitions that will be re-emitted by a differnt consumer.

This adds another `PartitionAssignmentHandler` which will add filtering in the stage so that
messages of partitions that were revoked are not issued anymore.
    @ennru
    ennru committed Oct 23, 2019
    Copy the full SHA
    d9d89a8 View commit details
    Browse the repository at this point in the history

  2. Exlicit imports to avoid mixing up KafkaConsumerActors

    @ennru
    ennru committed Oct 23, 2019
    Copy the full SHA
    81c3e5c View commit details
    Browse the repository at this point in the history