Documentation
¶
Index ¶
- func AddService(config service.Config)
- func BatchMessages(ctx context.Context, values <-chan kafka.Message, maxItems int, ...) chan []kafka.Message
- func GetWriterTopic() string
- func Handle(done, sendCtx context.Context, cancelSend context.CancelFunc, ...) <-chan kafka.Message
- func MessageAsString(message kafka.Message) string
- func MustProduce() bool
- func NewConsumer(done, sendCtx context.Context, kafkaURL string, wg *sync.WaitGroup) <-chan kafka.Message
- func NewProducer(done context.Context, cancelSend context.CancelFunc, kafkaURL string, ...)
- func Start() (close func())
- type SimpleMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddService ¶
func BatchMessages ¶ added in v0.3.5
func GetWriterTopic ¶ added in v0.3.12
func GetWriterTopic() string
func MessageAsString ¶ added in v0.3.9
func MustProduce ¶ added in v0.3.12
func MustProduce() bool
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.