()
| 1124 | } |
| 1125 | |
| 1126 | func (r *Reader) getTopicPartitionOffset() map[topicPartition]int64 { |
| 1127 | key := topicPartition{topic: r.config.Topic, partition: int32(r.config.Partition)} |
| 1128 | return map[topicPartition]int64{key: r.offset} |
| 1129 | } |
| 1130 | |
| 1131 | func (r *Reader) withLogger(do func(Logger)) { |
| 1132 | if r.config.Logger != nil { |
no outgoing calls
no test coverage detected