Consumer represents a Sarama consumer group consumer
| 162 | |
| 163 | // Consumer represents a Sarama consumer group consumer |
| 164 | type Consumer struct { |
| 165 | ready chan bool |
| 166 | } |
| 167 | |
| 168 | // Setup is run at the beginning of a new session, before ConsumeClaim |
| 169 | func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error { |
nothing calls this directly
no outgoing calls
no test coverage detected