kafka

package

v0.1.21 Latest Latest Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Kafka represents Kafka implementation

func New(conn *kafka.Conn) *Kafka

New creates new Kafka service

func NewWithConfig(conn *kafka.Conn, messaging *config.Messaging) *Kafka

NewWithConfig creates new Kafka service with messaging config

func (s *Kafka) Close() error

Close closes the Kafka service

func (s *Kafka) ConsumeMessages(ctx context.Context, topic string, groupID string, handler func([]byte) error) error

ConsumeMessages consumes messages from Kafka

func (s *Kafka) IsConnected() bool

IsConnected checks if the Kafka connection is valid

func (s *Kafka) PublishMessage(ctx context.Context, topic string, key, value []byte) error

PublishMessage publishes message to Kafka