- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for saramatls (0.11 sec)
-
internal/logger/target/kafka/kafka.go
import ( "context" "crypto/tls" "crypto/x509" "encoding/json" "errors" "fmt" "log" "os" "path/filepath" "sync" "sync/atomic" "time" "github.com/IBM/sarama" saramatls "github.com/IBM/sarama/tools/tls" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger/target/types" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/event/target/kafka.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" "github.com/IBM/sarama" saramatls "github.com/IBM/sarama/tools/tls" ) // Kafka input constants const ( KafkaBrokers = "brokers" KafkaTopic = "topic" KafkaQueueDir = "queue_dir"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0)