Documentation ¶
Index ¶
- Constants
- func NewJetStreamConsumer(nc *nats.Conn, js nats.JetStreamContext, stripPrefix string) sarama.Consumer
- func NewJetStreamProducer(nc *nats.Conn, js nats.JetStreamContext, stripPrefix string) sarama.SyncProducer
- type JetStreamConsumer
- func (c *JetStreamConsumer) Close() error
- func (c *JetStreamConsumer) ConsumePartition(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error)
- func (c *JetStreamConsumer) HighWaterMarks() map[string]map[int32]int64
- func (c *JetStreamConsumer) Partitions(topic string) ([]int32, error)
- func (c *JetStreamConsumer) Topics() (result []string, err error)
- type JetStreamProducer
Constants ¶
View Source
const MsgHeaderKey = "$_SARAMA_NATS_KEY"
MsgHeaderKey is the header used as the sarama.ConsumerMessage.Key
Variables ¶
This section is empty.
Functions ¶
func NewJetStreamConsumer ¶
func NewJetStreamConsumer(nc *nats.Conn, js nats.JetStreamContext, stripPrefix string) sarama.Consumer
NewJetStreamConsumer returns a sarama.Consumer
func NewJetStreamProducer ¶
func NewJetStreamProducer(nc *nats.Conn, js nats.JetStreamContext, stripPrefix string) sarama.SyncProducer
NewJetStreamProducer returns a sarama.SyncProducer
Types ¶
type JetStreamConsumer ¶
type JetStreamConsumer struct {
// contains filtered or unexported fields
}
JetStreamConsumer implements sarama.Consumer
func (*JetStreamConsumer) Close ¶
func (c *JetStreamConsumer) Close() error
Close implements sarama.Consumer
func (*JetStreamConsumer) ConsumePartition ¶
func (c *JetStreamConsumer) ConsumePartition(topic string, partition int32, offset int64) (sarama.PartitionConsumer, error)
ConsumePartition implements sarama.Consumer
func (*JetStreamConsumer) HighWaterMarks ¶
func (c *JetStreamConsumer) HighWaterMarks() map[string]map[int32]int64
HighWaterMarks implements sarama.Consumer
func (*JetStreamConsumer) Partitions ¶
func (c *JetStreamConsumer) Partitions(topic string) ([]int32, error)
Partitions implements sarama.Consumer
func (*JetStreamConsumer) Topics ¶
func (c *JetStreamConsumer) Topics() (result []string, err error)
Topics implements sarama.Consumer
type JetStreamProducer ¶
type JetStreamProducer struct {
// contains filtered or unexported fields
}
JetStreamProducer implements sarama.SyncProducer
func (*JetStreamProducer) Close ¶
func (p *JetStreamProducer) Close() error
Close implements sarama.SyncProducer
func (*JetStreamProducer) SendMessage ¶
func (p *JetStreamProducer) SendMessage(msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
SendMessage implements sarama.SyncProducer
func (*JetStreamProducer) SendMessages ¶
func (p *JetStreamProducer) SendMessages(msgs []*sarama.ProducerMessage) error
SendMessages implements sarama.SyncProducer
Click to show internal directories.
Click to hide internal directories.