Documentation
¶
Index ¶
- func Key(key string) broker.PublishOption
- func New(opts ...b.Option) b.Broker
- func PublishConfig(c *sarama.Config) broker.Option
- func SubscribeConfig(c *sarama.Config) broker.Option
- type Kafka
- func (broker *Kafka) Address() string
- func (broker *Kafka) Connect() error
- func (broker *Kafka) Disconnect() error
- func (broker *Kafka) Init(opts ...b.Option) error
- func (broker *Kafka) Options() b.Options
- func (broker *Kafka) Publish(ctx context.Context, topic string, msg *b.Message, opts ...b.PublishOption) error
- func (broker *Kafka) String() string
- func (broker *Kafka) Subscribe(topic string, h b.Handler, opts ...b.SubscribeOption) (b.Subscriber, error)
- type SendMessageResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Key ¶
func Key(key string) broker.PublishOption
Key The partitioning key for this message. Pre-existing Encoders include StringEncoder.
Types ¶
type Kafka ¶
type Kafka struct {
// contains filtered or unexported fields
}
func (*Kafka) Disconnect ¶
type SendMessageResponse ¶
type SendMessageResponse struct {
// contains filtered or unexported fields
}
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package otelsarama instruments the github.com/Shopify/sarama package.
|
Package otelsarama instruments the github.com/Shopify/sarama package. |
Click to show internal directories.
Click to hide internal directories.