rdhabalia opened a new pull request #8668:
URL: https://github.com/apache/pulsar/pull/8668
### Motivation
Right now, Kafka-connector/Debezium connector doesn't support tls with
source configuration which is used to create pulsar consumer for offset topic.
adding support of authentication with source-configuration
`pulsar.auth.plugin`, `pulsar.auth.plugin.param`,
`pulsar.tls.insecure.connection` , `pulsar.tls.trust.cert`
Sample command:
```
./pulsar-admin source localrun \
--name debezium-postgres-source \
--tenant pulsar \
--namespace us-west/ns1 \
--destination-topic-name persistent://pulsar/us-west/ns1/deb-dest \
--archive /pulsar-io-debezium-mysql.nar \
--processingGuarantees ATLEAST_ONCE \
--broker-service-url pulsar+ssl://my-cluster.com:6651/ \
--client-auth-params tlsCertFile:/client.cert.pem,tlsKeyFile:/client.key.pem
\
--client-auth-plugin org.apache.pulsar.client.impl.auth.AuthenticationTls \
--tls-trust-cert-path /ca.cert.pem \
--use-tls \
--source-config
'{"database.hostname":"db.com","database.port":"1111","database.user":"u1","database.password":"p1","database.dbname":"db","database.server.name":"s1","table.include.list":"t1","pulsar.service.url":"pulsar+ssl://my-cluster.com:6651","offset.storage.topic":"persistent://pulsar/us-west/ns1/deb-storage-topic","pulsar.auth.plugin":"org.apache.pulsar.client.impl.auth.AuthenticationTls",
"pulsar.auth.plugin.param":"tlsCertFile:/client.cert.pem,tlsKeyFile:/client.key.pem",
"pulsar.tls.insecure.connection":"true","pulsar.tls.trust.cert":"/ca.cert.pem"}'
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
