Important

You are viewing documentation for an older version of Confluent Platform. For the latest, click here.

RabbitMQ Source Connector Configuration Options

The RabbitMQ Source Connector Connector can be configured using a variety of configuration properties.

Connection

rabbitmq.host

The RabbitMQ host to connect to. See ConnectionFactory.setHost(java.lang.String)

  • Type: String
  • Importance: High
  • Default Value: localhost
rabbitmq.password

The password to authenticate to RabbitMQ with. See ConnectionFactory.setPassword(java.lang.String)

  • Type: String
  • Importance: High
  • Default Value: guest
rabbitmq.username

The username to authenticate to RabbitMQ with. See ConnectionFactory.setUsername(java.lang.String)

  • Type: String
  • Importance: High
  • Default Value: guest
rabbitmq.virtual.host

The virtual host to use when connecting to the broker. See ConnectionFactory.setVirtualHost(java.lang.String)

  • Type: String
  • Importance: High
  • Default Value: /
rabbitmq.port

The RabbitMQ port to connect to. See ConnectionFactory.setPort(int)

  • Type: Int
  • Importance: Medium
  • Default Value: 5672
rabbitmq.automatic.recovery.enabled

Enables or disables automatic connection recovery. See ConnectionFactory.setAutomaticRecoveryEnabled(boolean)

  • Type: Boolean
  • Importance: Low
  • Default Value: true
rabbitmq.connection.timeout.ms

Connection TCP establishment timeout in milliseconds. zero for infinite. See ConnectionFactory.setConnectionTimeout(int)

  • Type: Int
  • Importance: Low
  • Default Value: 60000
  • Valid Values: [0,…]
rabbitmq.handshake.timeout.ms

The AMQP0-9-1 protocol handshake timeout, in milliseconds. See ConnectionFactory.setHandshakeTimeout(int)

  • Type: Int
  • Importance: Low
  • Default Value: 10000
rabbitmq.network.recovery.interval.ms

See ConnectionFactory.setNetworkRecoveryInterval(long)

  • Type: Int
  • Importance: Low
  • Default Value: 10000
rabbitmq.requested.channel.max

Initially requested maximum channel number. Zero for unlimited. See ConnectionFactory.setRequestedChannelMax(int)

  • Type: Int
  • Importance: Low
  • Default Value: 0
rabbitmq.requested.frame.max

Initially requested maximum frame size, in octets. Zero for unlimited. See ConnectionFactory.setRequestedFrameMax(int)

  • Type: Int
  • Importance: Low
  • Default Value: 0
rabbitmq.requested.heartbeat.seconds

Set the requested heartbeat timeout. Heartbeat frames will be sent at about 1/2 the timeout interval. If server heartbeat timeout is configured to a non-zero value, this method can only be used to lower the value; otherwise any value provided by the client will be used. See ConnectionFactory.setRequestedHeartbeat(int)

  • Type: Int
  • Importance: Low
  • Default Value: 60
rabbitmq.shutdown.timeout.ms

Set the shutdown timeout. This is the amount of time that Consumer implementations have to continue working through deliveries (and other Consumer callbacks) after the connection has closed but before the ConsumerWorkService is torn down. If consumers exceed this timeout then any remaining queued deliveries (and other Consumer callbacks, including the Consumer’s handleShutdownSignal() invocation) will be lost. See ConnectionFactory.setShutdownTimeout(int)

  • Type: Int
  • Importance: Low
  • Default Value: 10000
rabbitmq.topology.recovery.enabled

Enables or disables topology recovery. See ConnectionFactory.setTopologyRecoveryEnabled(boolean)

  • Type: Boolean
  • Importance: Low
  • Default Value: true

Source

kafka.topic

Kafka topic to write the messages to.

  • Type: String
  • Importance: High
rabbitmq.queue

RabbitMQ queue to read from.

  • Type: List
  • Importance: High
rabbitmq.prefetch.count

Maximum number of messages that the server will deliver, 0 if unlimited. See Channel.basicQos(int, boolean)

  • Type: Int
  • Importance: Medium
  • Default Value: 0
rabbitmq.prefetch.global

True if the settings should be applied to the entire channel rather than each consumer. See Channel.basicQos(int, boolean)

  • Type: Boolean
  • Importance: Medium
  • Default Value: false