我对 kafka 非常陌生，我可以使用 3 个 Broker 在我的 Ec2 实例上设置 kafka。试验成功，我能够生产和消费消息。
However, my next goal is to create a msk cluster and write sqlcdc changes to topics in my MSK
Cluster.
I have my MSK Cluster and CDC enabled SQL Server EC2 Instance configured in same VPC. Both are
using same security groups.
My MSK cluster is using Encryption as SSL.
I Have whitelisted ports 9094 (Broker Port), 2181 (Zookeeper Port) and 1433 ( SQL Server
Port).
这是我的connector.properties文件内容.. ---------------------------------------- ---------------------- name=SQLServer-connector-test connector.class=io.debezium.connector.sqlserver.SqlServerConnector tasks.max=1 database.hostname = database.port=1433 database.user=sqladmin database.password=sql123 database.dbname=AdventureWorks2017 database.server.name=SQLCDC_SERVER table.include.list=HumanResources.Employee database.history.kafka.bootstrap.servers=b-2 .xxxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094,b- 3.xxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094,b-1.xxxxxxxx.c7.kafka .us-east- 1.amazonaws.com:9094 database.history.kafka.topic=HR_cdc #如果 kafka 已通过 TLS 身份验证，请取消以下行的注释。database.history.producer.security.protocol=SSL database.history.producer.ssl.truststore.location=/tmp/kafka.client.truststore.jks
Here are my worker properties file contents
--------------------------------------------
bootstrap.servers=-2.xxxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094,b-3.xxxxxxx.c7.kafka.us-
east-1.amazonaws.com:9094,b-1.xxxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
offset.storage.file.filename=/tmp/connect.offsets
rest.host.name=-2.xxxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094,b-3.xxxxxxx.c7.kafka.us-east-
1.amazonaws.com:9094,b-1.xxxxxxxx.c7.kafka.us-east-1.amazonaws.com:9094
rest.port=8083
-------------------------------------------------------------
Client.properties
--------------------
security.protocol=SSL
ssl.truststore.location=/tmp/kafka.client.truststore.jks
ssl.truststore.password=
ssl.endpoint.identification.algorithm=
-- When i try to start my worker by running the command as
> #command used as follows
> ./bin/connect-standalone ../worker.properties ../connector.properties ../client.properties
I get timeout error while connection to MSK cluster...
with error .. Check you broker configuration or security properties..
Unable to describe cluster
Do anyone come across the same error? If so, what was the solution?
Thanks you in advance.
***********************************************************************