Apache ActiveMQ® is the most popular open-source, multi-protocol, Java-based message broker. It supports industry-standard protocols so users get the benefits of client choices across a broad range of languages and platforms. Read more about ActiveMQ.
When to use this connector
- to read messages from and write messages to a given ActiveMQ queue.
- to implement a log-based CDC with a message queue.
Create a Connection
Step 1. In the
Connections window, click
+, and type in
Step 2. Select
Step 3. Enter the Connection parameters.
URL: the connection URL in the format
ssl://host:port. For example for ActiveMQ hosted on AWS:
Queue name: the optional ActiveMQ queue name.
User: the user name.
Password: the password.
Max number of records to read: the total maximum number of records to read from the queue. Set it to a reasonable number to allow the system to process records in micro-batches. If nothing is entered the system will read records from the queue until there are no more records.
Number of retries before stop polling: the number of retries before stop polling if poll returns no records.
Retry N minutes before stop pollingDelay between retries: the number of minutes to retry before stop polling if the poll returns no records.
Wait to get a next message (ms): the number of milliseconds to wait for a new message in the queue.
Value Serializer: the type of message to create. Options:
- String - the message is a string. Use it for text formats, such as JSNO, XML, etc.
- Array of bytes the message is an array of bytes. Use it for binary formats, such as Parquet or Avro.
- Object - use it to serialize Java objects.
Other parameters:additional configuration options for the ActiveMQ connection.