kafka

package

v0.1.2 Latest Latest Go to latest Published: May 15, 2025 License: Apache-2.0 Imports: 7 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 (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 with retries