kafka

type Broker struct {
	ID   string `json:"id,omitempty"`
	Addr string `json:"addr,omitempty"`
}

type ConfigEntry struct {
	Name      string
	Value     string
	ReadOnly  bool
	Default   bool
	Sensitive bool
}

type FlowKafka interface {
	CreateTopic(topic string, numPartitions int, replicationFactor int, retentionMs string) error
	DeleteTopic(topic string) error
	DescribeTopic(topic string) (*Topic, error)
	Pipe(ctx context.Context, c <-chan Message, topic string) error
	Produce(ctx context.Context, topic string, msg Message) error
	Read(ctx context.Context, topic string, bufferSize int) <-chan Message
	BrokerInfo(ctx context.Context) ([]Broker, error)
}

type Message struct {
	Key, Value []byte
}

type Metadata struct {
	Topics []*Topic
}

type ServiceConfig struct {
	BootstrapBroker string
	// contains filtered or unexported fields
}

type Topic struct {
	Name     string         `json:"name,omitempty"`
	Configs  []*ConfigEntry `json:"configs,omitempty"`
	ErrorMsg *string        `json:"errorMsg,omitempty"`
}