| 100 | const partitionConsumersBatchTimeout = 100 * time.Millisecond |
| 101 | |
| 102 | type consumer struct { |
| 103 | conf *Config |
| 104 | children map[string]map[int32]*partitionConsumer |
| 105 | brokerConsumers map[*Broker]*brokerConsumer |
| 106 | client Client |
| 107 | metricRegistry metrics.Registry |
| 108 | lock sync.Mutex |
| 109 | } |
| 110 | |
| 111 | // NewConsumer creates a new consumer using the given broker addresses and configuration. |
| 112 | func NewConsumer(addrs []string, config *Config) (Consumer, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected