-
Notifications
You must be signed in to change notification settings - Fork 2.3k
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
New component: RabbitMQ (data) Receiver #34242
Labels
Comments
frzifus
added
Sponsor Needed
New component seeking sponsor
needs triage
New item requiring triage
labels
Jul 24, 2024
Yesterday I got a poc up and running. It uses the existing retry logic of the rabbitmqexporter. To avoid hard to maintain copy pasta we may want to move this logic into e.g. Config receivers:
rabbitmqdata:
encoding_extension: otlp_encoding/rabbitmq
connection:
vhost: "/"
endpoint: amqp://localhost:5672
auth:
plain:
username: user
password: password
queue:
- name: otlp_metrics
consumer: col1
exclusive: true
exporters:
debug:
extensions:
otlp_encoding/rabbitmq:
protocol: otlp_json
service:
extensions: [otlp_encoding/rabbitmq]
pipelines:
metrics:
receivers: [rabbitmqdata]
exporters: [debug] Output |
Kind of a mouthful but |
codeboten
added a commit
that referenced
this issue
Aug 14, 2024
…#34361) This PR moves the retry logic from amqp publisher to amqp connection. Connection, client and other utility structures have been moved from `exporter/rabbitmqexporter/internal/publisher` to `internal/rabbitmq`. **Link to tracking Issue:** #34242 ---- cc @swar8080 @atoulme --------- Signed-off-by: Benedikt Bongartz <bongartz@klimlive.de> Co-authored-by: Alex Boten <223565+codeboten@users.noreply.github.com>
This was referenced Aug 27, 2024
f7o
pushed a commit
to f7o/opentelemetry-collector-contrib
that referenced
this issue
Sep 12, 2024
…open-telemetry#34361) This PR moves the retry logic from amqp publisher to amqp connection. Connection, client and other utility structures have been moved from `exporter/rabbitmqexporter/internal/publisher` to `internal/rabbitmq`. **Link to tracking Issue:** open-telemetry#34242 ---- cc @swar8080 @atoulme --------- Signed-off-by: Benedikt Bongartz <bongartz@klimlive.de> Co-authored-by: Alex Boten <223565+codeboten@users.noreply.github.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Labels
The purpose and use-cases of the new component
Since version v0.104.0 the opentelemetry collector includes a RabbitMQ exporter. While a rabbitmq receiver exists, it is only used to retrieve node metadata.
With the enhanced ability to read from the queue with an OpenTelemetry Collector, it can be used to reroute, manipulate, or further process traffic. #28891 (comment)
Example configuration for the component
Minimal receiver options required to ensure feature parity with exporter
Telemetry data types supported
Logs, metrics, and traces
Is this a vendor-specific component?
Code Owner(s)
@frzifus
Sponsor (optional)
No response
Additional context
Since an exporter and receiver already exist, does it make sense to add the desired functionality to the receiver?
Perhaps someone has an alternative name suggestion which is better then
RabbitMQDataReceiver
? 😅cc @atoulme @swar8080 @djaglowski @cpheps
The text was updated successfully, but these errors were encountered: