kafka

type Configuration struct {
	trigger.Configuration

	Brokers         []string
	Topics          []string
	ConsumerGroup   string
	InitialOffset   string
	BalanceStrategy string
	SASL            struct {
		Enable    bool
		Handshake bool
		User      string
		Password  string
		Mechanism string

		// oauth
		OAuth struct {
			ClientID     string
			ClientSecret string
			TokenURL     string
			Scopes       []string
		}
	}

	TLS struct {
		Enable             bool
		InsecureSkipVerify bool
		MinimumVersion     string
	}

	SecretPath string

	SessionTimeout                string
	HeartbeatInterval             string
	MaxProcessingTime             string
	RebalanceTimeout              string
	RebalanceRetryBackoff         string
	RetryBackoff                  string
	MaxWaitTime                   string
	MaxWaitHandlerDuringRebalance string
	WorkerAllocationMode          partitionworker.AllocationMode
	RebalanceRetryMax             int
	FetchMin                      int
	FetchDefault                  int
	FetchMax                      int
	ChannelBufferSize             int
	CACert                        string
	AccessKey                     string
	AccessCertificate             string
	LogLevel                      int
	AckWindowSize                 int
	Version                       string
	// contains filtered or unexported fields
}

type Event struct {
	nuclio.AbstractEvent
	// contains filtered or unexported fields
}

type SaramaLogger struct {
	// contains filtered or unexported fields
}