segmentio

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package kafka provides a kafka broker using segmentio

Index

Constants

This section is empty.

Variables

View Source
var (
	DefaultReaderConfig = kafka.WriterConfig{}
	DefaultWriterConfig = kafka.ReaderConfig{}
)

Functions

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func ReaderConfig

func ReaderConfig(c kafka.ReaderConfig) broker.Option

func SubscribeContext

func SubscribeContext(ctx context.Context) broker.SubscribeOption

SubscribeContext set the context for broker.SubscribeOption

func SubscribeReaderConfig

func SubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption

func SubscribeWriterConfig

func SubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption

func WriterConfig

func WriterConfig(c kafka.WriterConfig) broker.Option

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL