Skip to main content

MirrorMaker 2 with SSL

Hello. I was wondering if someone can help answer my question. I'm trying
to run MirrorMaker 2 in distributed mode using SSL. I have the distributor
running in SSL but when I can't get the curl REST api to do so. I saw that
kif-208 fixed this but I can't seem to implement it.

in my mm2-dist.prop file I have set:
////
listeners=https://localhost:8443
security.protocol=SSL
ssl.truststore.location=/home/ec2-user/kafka_2.13-2.7.0/cert/kafka.client.truststore.jks
////
my connector.json file look like this:

////
{
"name": "mm2-connect-cluster",
"config":{
"connector.class": "org.apache.kafka.connect.mirror.MirrorSourceConnector",
"connector.client.config.override.policy": "All",
"name": "mm2-connect-cluster",
"topics": "test.*",
"tasks.max": "1",
"source.cluster.alias": "source",
"target.cluster.alias": "target",
"source.cluster.bootstrap.servers": "source:9094",
"target.cluster.bootstrap.servers": "target:9094",
"source->target.enabled": "true",
"target->source.enabled": "false",
"offset-syncs.topic.replication.factor": "4",
"topics.exclude": ".*[\\-\\.]internal, .*\\.replica,
__consumer_offsets",
"groups.blacklist": "console-consumer-.*, connect-.*, __.*",
"topic.creation.enabled": "true",
"topic.creation.default.replication.factor": "4",
"topic.creation.default.partitions": "1"
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"security.protocol": "SSL",
"ssl.truststore.password":
"/home/ec2-user/kafka_2.13-2.7.0/cert/kafka.client.truststore.jks"
}
}
////

I would then start up the distributor and it launched fine. So I try to
run the CURl command

////
curl -s -X POST -H 'Content-Type: application/json' --data @connector.json
https://localhost:8443/connectors
////
nada. nothing. no error. no reasons for not starting.

Is it possible to run MM2 with SSL? If so, can someone point me to a
working example?

thanks.

Comments