Testing the `amqp` sink

Run amqp in docker using

docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password -p 5672:5672 -p 15672:15672 rabbitmq:management 

In the browser navigate to http://localhost:15672/#/exchanges. Log in with user, password. Click Add a new exchange. Create a new exchange called nork.

Run Vector with the following Sink configuration:

sinks:
  out:
    type: amqp
    inputs: 
      - in
    connection_string: amqp://user:[email protected]:5672/%2f?timeout=10
    exchange: nork
    encoding:
      codec: json