Documentation
¶
Index ¶
- func AddService(config service.Config)
- func BatchMessages(values <-chan kafka.Message, maxItems int, maxTimeout time.Duration) chan []kafka.Message
- func Handle(messages <-chan kafka.Message) <-chan kafka.Message
- func MessageAsString(message kafka.Message) string
- func NewConsumer(kafkaURL, topic, groupID string, done context.Context) <-chan kafka.Message
- func NewProducer(kafkaURL, topic string, in <-chan kafka.Message)
- func Start(done context.Context)
- func Writer(kafkaURL, topic string) *kafka.Writer
- type SimpleMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddService ¶
func BatchMessages ¶ added in v0.3.5
func MessageAsString ¶ added in v0.3.9
func NewConsumer ¶
func NewProducer ¶
Types ¶
type SimpleMessage ¶ added in v0.3.9
type SimpleMessage struct {
Topic string
Partition int
Offset int64
HighWaterMark int64
Headers []kafka.Header
Time time.Time
Key string
Value string
}
func MessageSimplified ¶ added in v0.3.9
func MessageSimplified(message kafka.Message) SimpleMessage
func MessagesSimplified ¶ added in v0.3.9
func MessagesSimplified(messages []kafka.Message) []SimpleMessage
Source Files
Click to show internal directories.
Click to hide internal directories.