kafka

package

v0.4.0 Latest Latest Go to latest Published: May 1, 2025 License: MIT Imports: 24 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	Topic        string
	Serializer   string
	TemplateType string
	// contains filtered or unexported fields
}

func (k *Manager) Close(_ context.Context) error

func (k *Manager) CreateTopic(ctx context.Context, topic string)

func (k *Manager) CreateTopicFull(ctx context.Context, topic string, partitions int, rf int)

func (k *Manager) Initialize(configFile string)

func (k *Manager) InitializeSchemaRegistry(configFile string)

func (k *Manager) Produce(_ context.Context, key []byte, data []byte, _ any)