kongkong

使用java-sdk的签名接口签名数据后，返回signDataStr。 验签的话，使用java-sdk的verify方法，代码见下。其中国密和ECDSA的输出signDataStr需要处理下： 国密：signDataStr 去掉00，去掉公钥.substring(2)字符串。 ECDSA: signDataStr 的前两位(00或04,,,)放后边。 ``` public boolean verifyByType(String publicKey, byte[] message, byte[] signature,int encryptType) { if (encryptType == CryptoType.SM_TYPE) { byte[] messageHash = smCryptoSuite.hash(message); return smCryptoSuite.verify(publicKey, messageHash,...

> [@zyyworktable](https://github.com/zyyworktable) One solution is to run cdc in the source milvus pod. This is mainly because the kafka connection library currently used depends on c++, which leads to this...

> [@Skkypy](https://github.com/Skkypy) This warning will not have any impact. This warning indicates that Kafka has been connected normally. After creating a new collection in my Milvus cluster with Kafka messaging...

> github.com/confluentinc/confluent-kafka-go/v2 v2.5.3 [kafka-go v2.5.3](https://github.com/confluentinc/confluent-kafka-go/tree/v2.5.3) Is there anything I missed ? `kafka` folder isn't include this go file `kafka_consumer.go`