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

SINK amqp doesnt reconnect #22313

Open
priprd opened this issue Jan 28, 2025 · 0 comments
Open

SINK amqp doesnt reconnect #22313

priprd opened this issue Jan 28, 2025 · 0 comments
Labels
sink: amqp Anything `amqp` sink related type: bug A code related bug.

Comments

@priprd
Copy link

priprd commented Jan 28, 2025

A note for the community

  • Please vote on this issue by adding a 👍 reaction to the original issue to help the community and maintainers prioritize this request
  • If you are interested in working on this issue or have submitted a pull request, please leave a comment

Problem

Sink amqp stop after rabbitmq will be restarterd ( rollout restart). Need restart completly vector container.

Configuration

sink:
 amqp:
        type: amqp
        connection_string: "amqp://${RABBITMQ_USER}:${RABBITMQ_PASS}@${RABBITMQ_HOST}:${RABBITMQ_PORT}/${RABBITMQ_VHOST}?timeout=60"
        exchange: "logs"
        inputs: ["rabbit_out_csv","postgres_logs_defaults"]
        encoding:
          codec: "json"

Version

vector:0.41.1-debian

Debug Output

"Internal log [Events dropped] has been suppressed 3 times."

"Internal log [Service call failed. No retries or retries exhausted.] has been suppressed 3 times."

"2025-01-27T07:59:56.585659Z ERROR sink{component_kind=\"sink\" component_id=amqp component_type=amqp}:request{request_id=821974}: vector_common::internal_event::component_events_dropped: Events dropped intentional=false count=1 reason=\"Service call failed. No retries or retries exhausted.\" internal_log_rate_limit=true"

Example Data

No response

Additional Context

We are running vector as sidecar container for collecting logs from files and transform to multiple sinks. Restart completly pod its very hard.
Its possible some one has more retries?

References

No response

@priprd priprd added the type: bug A code related bug. label Jan 28, 2025
@pront pront added the sink: amqp Anything `amqp` sink related label Jan 28, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
sink: amqp Anything `amqp` sink related type: bug A code related bug.
Projects
None yet
Development

No branches or pull requests

2 participants