kafka

package

v1.10.9 Latest Latest Go to latest Published: Jun 20, 2023 License: Apache-2.0 Imports: 5 Imported by: 6

Details

This section is empty.

This section is empty.

func NewKafka(logger logger.Logger) pubsub.PubSub

NewKafka returns a new kafka pubsub instance.

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

func (p *PubSub) BulkPublish(ctx context.Context, req *pubsub.BulkPublishRequest) (pubsub.BulkPublishResponse, error)

BatchPublish messages to Kafka cluster.

func (p *PubSub) BulkSubscribe(ctx context.Context, req pubsub.SubscribeRequest,
	handler pubsub.BulkHandler,
) error

func (p *PubSub) Close() (err error)

func (p *PubSub) Features() []pubsub.Feature

func (p *PubSub) Init(metadata pubsub.Metadata) error

func (p *PubSub) Publish(ctx context.Context, req *pubsub.PublishRequest) error

Publish message to Kafka cluster.

func (p *PubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error