factory

func CreateMemoryProfileHandler ¶

func CreateMemoryProfileHandler() http.Handler

func CreateOffsetManagerHandler ¶

func CreateOffsetManagerHandler(db libkv.DB, cancel context.CancelFunc) http.Handler

CreateOffsetManagerHandler creates a standardized HTTP handler for DB-based offset management. This handler provides a RESTful interface to manage Kafka consumer offsets stored in a database.

Parameters:

• db: Database connection for storing offset information
• cancel: Context cancellation function for graceful shutdown

Returns an HTTP handler that can be mounted at /offsetmanager endpoint.

Example usage:

router.Path("/offsetmanager").Handler(factory.CreateOffsetManagerHandler(db, cancel))

func CreateResetBucketHandler ¶

func CreateResetBucketHandler(db libkv.DB, cancel context.CancelFunc) http.Handler

func CreateResetHandler ¶

func CreateResetHandler(db libkv.DB, cancel context.CancelFunc) http.Handler

func CreateSaramaOffsetManagerHandler ¶

func CreateSaramaOffsetManagerHandler(
	saramaClientProvider libkafka.SaramaClientProvider,
	group libkafka.Group,
	cancel context.CancelFunc,
) http.Handler

CreateSaramaOffsetManagerHandler creates a standardized HTTP handler for Sarama-based offset management. This handler provides a RESTful interface to manage Kafka consumer offsets using Sarama client.

Parameters:

• saramaClient: Sarama Kafka client for offset operations
• group: Kafka consumer group for offset management
• cancel: Context cancellation function for graceful shutdown

Returns an HTTP handler that can be mounted at /offsetmanager endpoint.

Example usage:

router.Path("/offsetmanager").Handler(factory.CreateSaramaOffsetManagerHandler(saramaClient, group, cancel))

func CreateSetLoglevelHandler ¶

func CreateSetLoglevelHandler(ctx context.Context) http.Handler

func NewSyncProducerWithName ¶

func NewSyncProducerWithName(
	ctx context.Context,
	brokers libkafka.Brokers,
	name string,
	opts ...libkafka.SaramaConfigOptions,
) (libkafka.SyncProducer, error)

NewSyncProducerWithName creates a sync producer that adds a 'name' header to all messages.