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

Faust Application is creating internal topics which should not be created #149

Closed
2 tasks
Prashant-1305 opened this issue May 14, 2021 · 2 comments
Closed
2 tasks

Comments

@Prashant-1305
Copy link

Checklist

  • I have included information about relevant versions
  • I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

When the application is initialized in a Kafka Cluster Faust is creating an internal topic which is not being used. This is getting created with default settings.

Tell us what you did to cause something to happen.

Expected behavior

Internal topic shouldn't be created in Kafka Clusters
Tell us what you expected to happen.

Actual behavior

Tell us what happened instead.

Full traceback

Paste the full traceback (if there is any)

Versions

  • Python version 3.8
  • Faust version 6.1
  • Operating system
  • Kafka version 1.4.2
  • RocksDB version (if applicable)
@patkivikram
Copy link
Collaborator

I believe the problem here is the internal *__assigner__leader topic which is created here is not honoring the replication factor set by the app.

@Prashant-1305
Copy link
Author

Yes thats correct, __assignor-__leader is not honoring the replication factor set by the app

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