Skip to content

Commit 2fd48b6

Browse files
vdesabouvdesabou
committed
minor
1 parent 58cec2b commit 2fd48b6

File tree

2 files changed

+45
-45
lines changed

2 files changed

+45
-45
lines changed

‎connect/connect-replicator/replicator-2way-ssl.sh

+33-33
Original file line numberDiff line numberDiff line change
@@ -19,39 +19,39 @@ EOF
1919
log "Creating Confluent Replicator connector with SSL authentication"
2020
playground connector create-or-update --connector duplicate-topic-ssl << EOF
2121
{
22-
"connector.class":"io.confluent.connect.replicator.ReplicatorSourceConnector",
23-
"key.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
24-
"value.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
25-
"header.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
26-
"src.consumer.group.id": "duplicate-topic",
27-
"confluent.topic.bootstrap.servers": "broker:9092",
28-
"confluent.topic.replication.factor": "1",
29-
"confluent.topic.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
30-
"confluent.topic.ssl.keystore.password" : "confluent",
31-
"confluent.topic.ssl.key.password" : "confluent",
32-
"confluent.topic.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
33-
"confluent.topic.ssl.truststore.password" : "confluent",
34-
"confluent.topic.ssl.keystore.type" : "JKS",
35-
"confluent.topic.ssl.truststore.type" : "JKS",
36-
"confluent.topic.security.protocol" : "SSL",
37-
"provenance.header.enable": true,
38-
"topic.whitelist": "test-topic-ssl",
39-
"topic.rename.format": "test-topic-ssl-duplicate",
40-
"dest.kafka.bootstrap.servers": "broker:9092",
41-
"dest.kafka.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
42-
"dest.kafka.ssl.keystore.password" : "confluent",
43-
"dest.kafka.ssl.key.password" : "confluent",
44-
"dest.kafka.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
45-
"dest.kafka.ssl.truststore.password" : "confluent",
46-
"dest.kafka.security.protocol" : "SSL",
47-
"src.kafka.bootstrap.servers": "broker:9092",
48-
"src.kafka.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
49-
"src.kafka.ssl.keystore.password" : "confluent",
50-
"src.kafka.ssl.key.password" : "confluent",
51-
"src.kafka.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
52-
"src.kafka.ssl.truststore.password" : "confluent",
53-
"src.kafka.security.protocol" : "SSL"
54-
}
22+
"connector.class":"io.confluent.connect.replicator.ReplicatorSourceConnector",
23+
"key.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
24+
"value.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
25+
"header.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
26+
"src.consumer.group.id": "duplicate-topic",
27+
"confluent.topic.bootstrap.servers": "broker:9092",
28+
"confluent.topic.replication.factor": "1",
29+
"confluent.topic.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
30+
"confluent.topic.ssl.keystore.password" : "confluent",
31+
"confluent.topic.ssl.key.password" : "confluent",
32+
"confluent.topic.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
33+
"confluent.topic.ssl.truststore.password" : "confluent",
34+
"confluent.topic.ssl.keystore.type" : "JKS",
35+
"confluent.topic.ssl.truststore.type" : "JKS",
36+
"confluent.topic.security.protocol" : "SSL",
37+
"provenance.header.enable": true,
38+
"topic.whitelist": "test-topic-ssl",
39+
"topic.rename.format": "test-topic-ssl-duplicate",
40+
"dest.kafka.bootstrap.servers": "broker:9092",
41+
"dest.kafka.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
42+
"dest.kafka.ssl.keystore.password" : "confluent",
43+
"dest.kafka.ssl.key.password" : "confluent",
44+
"dest.kafka.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
45+
"dest.kafka.ssl.truststore.password" : "confluent",
46+
"dest.kafka.security.protocol" : "SSL",
47+
"src.kafka.bootstrap.servers": "broker:9092",
48+
"src.kafka.ssl.keystore.location" : "/etc/kafka/secrets/kafka.connect.keystore.jks",
49+
"src.kafka.ssl.keystore.password" : "confluent",
50+
"src.kafka.ssl.key.password" : "confluent",
51+
"src.kafka.ssl.truststore.location" : "/etc/kafka/secrets/kafka.connect.truststore.jks",
52+
"src.kafka.ssl.truststore.password" : "confluent",
53+
"src.kafka.security.protocol" : "SSL"
54+
}
5555
EOF
5656

5757

‎connect/connect-replicator/replicator.sh

+12-12
Original file line numberDiff line numberDiff line change
@@ -15,18 +15,18 @@ EOF
1515
log "Creating Replicator connector"
1616
playground connector create-or-update --connector duplicate-topic << EOF
1717
{
18-
"connector.class":"io.confluent.connect.replicator.ReplicatorSourceConnector",
19-
"key.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
20-
"value.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
21-
"header.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
22-
"src.consumer.group.id": "duplicate-topic",
23-
"confluent.topic.replication.factor": 1,
24-
"provenance.header.enable": true,
25-
"topic.whitelist": "test-topic",
26-
"topic.rename.format": "test-topic-duplicate",
27-
"dest.kafka.bootstrap.servers": "broker:9092",
28-
"src.kafka.bootstrap.servers": "broker:9092"
29-
}
18+
"connector.class":"io.confluent.connect.replicator.ReplicatorSourceConnector",
19+
"key.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
20+
"value.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
21+
"header.converter": "io.confluent.connect.replicator.util.ByteArrayConverter",
22+
"src.consumer.group.id": "duplicate-topic",
23+
"confluent.topic.replication.factor": 1,
24+
"provenance.header.enable": true,
25+
"topic.whitelist": "test-topic",
26+
"topic.rename.format": "test-topic-duplicate",
27+
"dest.kafka.bootstrap.servers": "broker:9092",
28+
"src.kafka.bootstrap.servers": "broker:9092"
29+
}
3030
EOF
3131

3232
sleep 10

0 commit comments

Comments
 (0)