|
|
@ -6,15 +6,22 @@ import ( |
|
|
|
|
|
|
|
|
|
|
|
type KafkaReader struct { |
|
|
|
type KafkaReader struct { |
|
|
|
reader *kafka.Reader |
|
|
|
reader *kafka.Reader |
|
|
|
|
|
|
|
first string |
|
|
|
|
|
|
|
topic string |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func NewReader(topic string, address ...string) *KafkaReader { |
|
|
|
func NewReader(topic string, address ...string) *KafkaReader { |
|
|
|
return &KafkaReader{ |
|
|
|
return &KafkaReader{ |
|
|
|
// reader: &kafka.Reader{
|
|
|
|
reader: kafka.NewReader(kafka.ReaderConfig{ |
|
|
|
// Topic: topic,
|
|
|
|
Topic: topic, |
|
|
|
// Balancer: &kafka.LeastBytes{},
|
|
|
|
Brokers: address, |
|
|
|
// Addr: kafka.TCP(address...),
|
|
|
|
GroupID: "consumer-group-id", // TODO
|
|
|
|
// },
|
|
|
|
Partition: 0, // TODO
|
|
|
|
|
|
|
|
MinBytes: 10e3, // 10KB
|
|
|
|
|
|
|
|
MaxBytes: 10e6, // 10MB
|
|
|
|
|
|
|
|
}), |
|
|
|
|
|
|
|
first: address[0], |
|
|
|
|
|
|
|
topic: topic, |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|