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.

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

Safely stop(close replication-producer) and remove replicator #159

Merged
merged 1 commit into from
Jan 4, 2017

Conversation

rdhabalia
Copy link
Contributor

Motivation

Based on #152 (creating patch to branch-1.15) - Safely close replication-producer while disconnecting replicator

  • While deleting replication-cluster of the topic: Sometime broker fails to delete replicator-cursor and it tries to restart even after closing the cursor. It causes broker to retries cursor-recovery for already deleted replicator-cluster.

Modifications

  • On replicator-disconnect: close producer even it's not connected with remote yet.
  • Avoid restarting of replicator when get error while deleting cursor.

Result

  • It will prevent producer to reconnect event after replicator disconnection
  • It will prevent broker to keep retrying cursor recovery for already deleted replication-cluster.

@rdhabalia rdhabalia added the type/bug The PR fixed a bug or issue reported a bug label Jan 3, 2017
@rdhabalia rdhabalia self-assigned this Jan 3, 2017
@yahoocla
Copy link

yahoocla commented Jan 3, 2017

CLA is valid!

1 similar comment
@yahoocla
Copy link

yahoocla commented Jan 3, 2017

CLA is valid!

@rdhabalia rdhabalia force-pushed the replicator branch 2 times, most recently from 0f09588 to d81c0b3 Compare January 3, 2017 23:12
Copy link
Contributor

@saandrews saandrews left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good

POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS, th);
brokerService.executor().schedule(this::checkReplication, POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS,
TimeUnit.SECONDS);
result.completeExceptionally(th);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We should have a way to prevent this going in loop

@rdhabalia rdhabalia merged commit c10ae7c into apache:branch-1.15 Jan 4, 2017
@rdhabalia rdhabalia deleted the replicator branch January 23, 2017 22:03
sijie pushed a commit to sijie/pulsar that referenced this pull request Mar 4, 2018
* Remove logic of supported types since serde is now exposed to the user

* Fix test
hrsakai pushed a commit to hrsakai/pulsar that referenced this pull request Dec 10, 2020
We should error on the side of readability in
code base so we don't need the maligned lint flag.
hangc0276 pushed a commit to hangc0276/pulsar that referenced this pull request May 26, 2021
Co-authored-by: dockerzhang(张超) <dockerzhang@tencent.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants