Confluent offer an Active MQ Source connector as part of the Confluent platform, under the “Confluent Software Evaluation License”.
We offer an Active MQ Sink Connector. You’re free to use it under the MIT license!
Limitations
For the first release, functionality is limited to writing to an ActiveMQ Queue. SMT Transforms are not yet supported.
There may well be more limitations. Feel free to get in touch, either here or through gitHub (Pull Requests welcome).
Usage
There is an automated test that shows how to use the connector.
tl;dr
As with the normal process for Kafka Connectors, ensure you install the JAR (from maven central) onto your Kafka Connect instance(s). You then need to configure the connector, eg using curl:
curl -X POST \
-H "Content-Type: application/json" \
http://localhost:8083/connectors \
--data '{
"name": "activeMqSinkConnector",
"config": {
"connector.class": "com.aimyourtechnology.kafka.connect.activemq.connector.ActiveMqSinkConnector",
"activemq.endpoint": "tcp://localhost:61616",
"activemq.queue": "target-mq-queue",
"topics": "kafka-topic",
"kafka.bootstrap.servers": "broker:29092",
}
}'