Documentation
¶
Overview ¶
Package kafka provides a Kafka implementation of the MessageQueueReader interface. It allows reading messages from Apache Kafka topics without committing offsets.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaReader ¶
type KafkaReader struct {
// contains filtered or unexported fields
}
KafkaReader implements MessageQueueReader for Apache Kafka
func NewKafkaReader ¶
func NewKafkaReader(cfg *mqreader.Config) (*KafkaReader, error)
NewKafkaReader creates a new Kafka reader from a config
func (*KafkaReader) Connect ¶
func (r *KafkaReader) Connect(ctx context.Context) error
Connect establishes connection to Kafka
func (*KafkaReader) GetMetadata ¶
func (r *KafkaReader) GetMetadata(ctx context.Context) (*mqreader.QueueMetadata, error)
GetMetadata returns information about the topic
Source Files
Click to show internal directories.
Click to hide internal directories.