Example Configurations¶

The following sections require running Apache Kafka® and Connect. For more information, see the Tutorial: Moving Data In and Out of Kafka. Note that as of Confluent Platform 7.5, ZooKeeper is deprecated for new deployments. Confluent recommends KRaft mode for new deployments. For more information, see the KRaft documentation page.

Standalone¶

The first configuration is used typically along with standalone workers.

name=connector1
tasks.max=1
connector.class=io.confluent.connect.activemq.ActiveMQSourceConnector
# The following values must be configured.
kafka.topic=MyKafkaTopicName
activemq.url=tcp://localhost:61616
jms.destination.name=testing
# The following define the information used to validate the license stored in Kafka
# or leave blank for a 30 day trial
confluent.license=
confluent.topic.bootstrap.servers=localhost:9092

You can change the confluent.topic.* properties to fit your specific environment. If running on a single-node Kafka cluster, you must include the following: "confluent.topic.replication.factor":"1". Leave the confluent.license property blank for a 30-day trial. For more details, see the configuration options.

To explore other options when connecting to ActiveMQ, see the Configuration Reference for ActiveMQ Source Connector for Confluent Platform page. For details about the ActiveMQ URL parameters, see the Apache ActiveMQ documentation.

Distributed¶

This configuration is used typically along with distributed mode.

Create a file named connector.json using the following JSON configuration example:
```
{
   "name": "connector1",
   "config": {
      "connector.class": "io.confluent.connect.activemq.ActiveMQSourceConnector",
      "kafka.topic":"MyKafkaTopicName",
      "activemq.url":"tcp://localhost:61616",
      "jms.destination.name":"testing",
      "confluent.license":"",
      "confluent.topic.bootstrap.servers":"localhost:9092"
   }
}
```
You can change the confluent.topic.* properties to fit your specific environment. If running on a single-node Kafka cluster, you must include the following: "confluent.topic.replication.factor":"1". Leave the confluent.license property blank for a 30-day trial. For more details, see the configuration options.

To explore other options when connecting to ActiveMQ, see the Configuration Reference for ActiveMQ Source Connector for Confluent Platform page. For details about the ActiveMQ URL parameters, see the Apache ActiveMQ documentation.
Use curl to post the configuration to one of the Kafka Connect Workers. Change http://localhost:8083/ the endpoint of one of your Kafka Connect worker(s).
```
curl -s -X POST -H 'Content-Type: application/json' --data @connector.json http://localhost:8083/connectors
```