Skip to content

SINK amqp doesnt reconnect #22313

Open
@priprd

Description

@priprd

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    sink: amqpAnything `amqp` sink relatedtype: bugA code related bug.

    Type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions