我需要使用信任庫和密鑰庫與客戶端建立 TLS 連接。我的商店采用 P12 格式。我的密鑰庫只有一把私鑰和一把公鑰。我的信任庫只有一個集群證書。我的問題是，我無法連接到我的 ssl-Kafka。可能握手失敗，但 kafka-go 不打印任何消息。下面是我的代碼。也許有配置問題？有誰知道如何打印錯誤？或者也許我的配置錯誤在哪里？getKafkaReader(topic string) *kafka.Reader { if consumer == nil { consumer = kafka.NewReader(kafka.ReaderConfig{ Brokers: []string{kafkaConfig.Host}, GroupID: os.Getenv("KAFKA_CONSUMER_GROUP"), Topic: topic, Partition: 0, MinBytes: 10e2, // 1KB MaxBytes: 10e5, // 1MB Dialer: getDialer(), }) } return consumer}func getDialer() *kafka.Dialer { dialer := &kafka.Dialer{ Timeout: 5 * time.Second, DualStack: true, TLS: tlsConfig(), } return dialer}func tlsConfig() *tls.Config { // Keystore keys, _ := ioutil.ReadFile(kafkaConfig.KeyStoreLocation) blocks, err := p12.ToPEM(keys, kafkaConfig.KeyStorePassword) if err != nil { log.Fatal(err.Error()) } var pemData []byte for test, b := range blocks { _ = test pemData = append(pemData, pem.EncodeToMemory(b)...) } cert, err := tls.X509KeyPair(pemData, pemData) if err != nil { log.Fatal(err.Error()) } //Truststore caCert, err := ioutil.ReadFile("./certificates/ca.pem") if err != nil { log.Fatal(err) } caCertPool := x509.NewCertPool() caCertPool.AppendCertsFromPEM(caCert) config := &tls.Config{ Certificates: []tls.Certificate{cert}, RootCAs: caCertPool, } return config}
1 回答
呼喚遠(yuǎn)方
TA貢獻(xiàn)1856條經(jīng)驗 獲得超11個贊
我有答案了。我有自簽名證書。這就是為什么我必須設(shè)置
tlsConfig.InsecureSkipVerify = true
- 1 回答
- 0 關(guān)注
- 192 瀏覽
添加回答
舉報
0/150
提交
取消