@ -17,9 +17,10 @@ package kafka
import (
"context"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
"github.com/OpenIMSDK/tools/log"
"github.com/Shopify/sarama"
)
@ -1,9 +1,10 @@
package kafka
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/tls"
// SetupTLSConfig set up the TLS config from config file.
@ -10,7 +10,6 @@ import (
func decryptPEM(data []byte, passphrase []byte) ([]byte, error) {
if len(passphrase) == 0 {
return data, nil