consumer

package

v0.0.0-...-2c759a0 Latest Latest Go to latest Published: May 22, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation ¶

Index ¶

Variables
func HyperauthConsumer()
func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)
type Consumer
type TopicEvent

Constants ¶

This section is empty.

Variables ¶

View Source

var KafkaGroupId string

Functions ¶

func HyperauthConsumer ¶

func HyperauthConsumer()

func NewTLSConfig ¶

func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)

Types ¶

type Consumer ¶

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

Consumer represents a Sarama consumer group consumer

func (*Consumer) Cleanup ¶

func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error

Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited

func (*Consumer) ConsumeClaim ¶

func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().

func (*Consumer) Setup ¶

func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error

Setup is run at the beginning of a new session, before ConsumeClaim

type TopicEvent ¶

type TopicEvent struct {
	Type      string            `json:"type"`
	UserName  string            `json:"userName"`
	UserId    string            `json:"userId"`
	Time      float32           `json:"time"`
	RealmId   string            `json:"realmId"`
	ClientId  string            `json:"clientId"`
	SessionId string            `json:"sessionId"`
	IpAddress string            `json:"ipAddress"`
	Error     string            `json:"error"`
	Details   map[string]string `json:"details"`
}

Source Files ¶

View all Source files

kafkaConsumer.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL