kafka

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

type Kafka interface {
	PublishMessage(ctx context.Context, topic string, key, value []byte, options PublishOptions) error
	Subscribe(ctx context.Context, topic string, processMessage func(topic string, key, value []byte), options SubscriptionOptions) error
}

type Message struct {
	Topic string
	Key   []byte
	Value []byte
}

type PublishOptions struct {
	Partition *int
}

type SubscriptionOptions struct {
	GroupID     *string
	Partition   *int
	StartOffset *int64
}