Documentation ¶
Index ¶
Constants ¶
View Source
const ( OFFSET_NEWEST = sarama.OffsetNewest OFFSET_OLDEST = sarama.OffsetOldest )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConsumer ¶
type KafkaConsumer struct { Address string Topic string ClientID string // contains filtered or unexported fields }
func NewKafkaConsumer ¶
func NewKafkaConsumer() *KafkaConsumer
func (*KafkaConsumer) Close ¶
func (k *KafkaConsumer) Close() error
func (*KafkaConsumer) Connect ¶
func (k *KafkaConsumer) Connect() error
func (*KafkaConsumer) NewPartitionConsumer ¶
func (k *KafkaConsumer) NewPartitionConsumer(offset int64) (*sarama.PartitionConsumer, error)
type KafkaProducer ¶
type KafkaProducer struct { Address string Topic string ClientID string // contains filtered or unexported fields }
func NewKafkaProducer ¶
func NewKafkaProducer() *KafkaProducer
func (*KafkaProducer) Close ¶
func (k *KafkaProducer) Close() error
func (*KafkaProducer) Connect ¶
func (k *KafkaProducer) Connect() error
Click to show internal directories.
Click to hide internal directories.