Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for V2 (0.11 sec)

  1. internal/event/target/kafka.go

    	"strings"
    	"time"
    
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v2/net"
    
    	"github.com/IBM/sarama"
    	saramatls "github.com/IBM/sarama/tools/tls"
    )
    
    // Kafka input constants
    const (
    	KafkaBrokers          = "brokers"
    	KafkaTopic            = "topic"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	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"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    // the suffix for the configured queue dir where the logs will be persisted.
    const kafkaLoggerExtension = ".kafka.log"
    
    const (
    	statusClosed = iota
    	statusOffline
    	statusOnline
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
Back to top