-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
[receiver/kafka]: support receiving from multiple topics #33204
Comments
Pinging code owners:
See Adding Labels via Comments if you do not have permissions to add labels yourself. |
Could be related to #32735. |
This issue has been inactive for 60 days. It will be closed in 60 days if there is no activity. To ping code owners by adding a component label, see Adding Labels via Comments, or if you are unsure of which component this issue relates to, please ping Pinging code owners:
See Adding Labels via Comments if you do not have permissions to add labels yourself. |
This issue has been closed as inactive because it has been stale for 120 days with no activity. |
Component(s)
receiver/kafka
Is your feature request related to a problem? Please describe.
I want to collect logs from multiple Kubernetes clusters using opentelemetry collector, and send them to elasticsearch.
My setup briefly looks like this:
collectors (in k8s clusters) --> kafka --> collector (centralized) --> elasticsearch
I want to use multiple topics on kafka in order to mitigate noisy neighbor situations.
topic_from_attribute
configuration on kafka exporter helps me to send logs to separate topics easily, but there is no way to provide a topic pattern or regex for consuming from multiple topics. As a result, I need to automate the process of adding/removing kafka receivers on my centralized collector's config and I'm not sure that it will be a problem to add ~500 kafka receivers on collector config.Describe the solution you'd like
Instead of this:
I want to be able to provide a pattern or regexp.
Note: Collector should also periodically check all topics and update the listened topic list based on the
topicPattern
.Describe alternatives you've considered
I'm open to any other solutions or recommendations.
Additional context
No response
The text was updated successfully, but these errors were encountered: