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

Support retrying on a different cluster #117

Open
mauhiz opened this issue Jul 13, 2021 · 3 comments
Open

Support retrying on a different cluster #117

mauhiz opened this issue Jul 13, 2021 · 3 comments

Comments

@mauhiz
Copy link
Contributor

mauhiz commented Jul 13, 2021

Retry producer can be configured to use a different cluster but retry consumer cannot. (shares the consumer with the original one)

While this is saves resources in most cases, it prevents enabling retry feature on a cluster you can't freely create topics on.

@kawamuray
Copy link
Member

Yeah.. I know few users who've tried to do that and turns out it can't.
While the needs of this feature is totally understandable, as currently decaton uses one consumer to consume both the original topic and the retry topic, separating consumer instance for these will be non-trivial change.

As a workaround, I think you can create and run a decaton subscription for the retry topic besides the original subscription that consumes the original topic and produces retry tasks to the another touchable cluster. Would it be inconvenient?

@mauhiz
Copy link
Contributor Author

mauhiz commented Jul 15, 2021

if retry is configured, it will start a consumer on the wrong cluster; and the update metadata request will last forever due to #118

@kawamuray
Copy link
Member

Ugh, that's true. Then solution here would be either one of:

  • Decaton supports retry topic in a different cluster or
  • Use poll(Duration) #118 + option to disable retry "consumer" in a subscription

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants