kafka

package

v0.0.0-...-db9a40e Latest Latest Go to latest Published: Oct 1, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation ¶

const KafkaMaxMessageBytes = 16 * 1024

This section is empty.

func NewKafkaMessageBus(host string, port int, topic string, tlsCfg *KafkaTLSConfig) (messagebus.Messagebus, error)

func NewKafkaMessageBusFromConn(conn *kafka.Conn, topic string) (messagebus.Messagebus, error)

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

func (m *KafkaMessagebus) Close() error

func (m *KafkaMessagebus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)

func (m *KafkaMessagebus) RecieveLoop(conn *kafka.Conn, message chan<- string, queue string)

func (m *KafkaMessagebus) SendMessage(message []byte, queue string) error

func (m *KafkaMessagebus) SendMessageWithHeaders(message []byte, queue string, headers map[string]string) error

func (m *KafkaMessagebus) TopicConnect(queue string) (*kafka.Conn, error)

type KafkaSubscription struct {
}

func (m *KafkaSubscription) Close() error

type KafkaTLSConfig struct {
	ServerCA   string
	ClientCert string
	ClientKey  string
	SkipVerify bool // skip hostname check
}