Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKafkaTopic ¶
Types ¶
type KafkaConsumer ¶
type KafkaConsumer interface {
Consume(ctx context.Context, topic string, groupID string, handler func(kafka.Message) error) error
}
func NewKafkaConsumer ¶
func NewKafkaConsumer(brokers []string, groupID string, groupTopics []string) KafkaConsumer
type KafkaProducer ¶
type KafkaProducer interface {
Produce(ctx context.Context, topic string, message kafka.Message) error
}
func NewKafkaProducer ¶
func NewKafkaProducer(brokers []string) KafkaProducer
type KafkaTopic ¶
Source Files
Click to show internal directories.
Click to hide internal directories.