File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -102,12 +102,12 @@ type SaramaMessageConsumer struct {
102102 MessageConsumer
103103}
104104
105- // Cleanup implements sarama.ConsumerGroupHandler.sarama.ConsumeGroupHandler.
105+ // Cleanup implements sarama.ConsumerGroupHandler.
106106func (c * SaramaMessageConsumer ) Cleanup (_ sarama.ConsumerGroupSession ) error {
107107 return nil
108108}
109109
110- // ConsumeClaim implements sarama.ConsumerGroupHandler.sarama.ConsumeGroupHandler.
110+ // ConsumeClaim implements sarama.ConsumerGroupHandler.
111111func (c * SaramaMessageConsumer ) ConsumeClaim (session sarama.ConsumerGroupSession , claim sarama.ConsumerGroupClaim ) error {
112112 for message := range claim .Messages () {
113113 if err := c .HandleKafkaMessage (message ); err != nil {
@@ -120,7 +120,7 @@ func (c *SaramaMessageConsumer) ConsumeClaim(session sarama.ConsumerGroupSession
120120 return nil
121121}
122122
123- // Setup implements sarama.ConsumerGroupHandler.sarama.ConsumeGroupHandler.
123+ // Setup implements sarama.ConsumerGroupHandler.
124124func (c * SaramaMessageConsumer ) Setup (_ sarama.ConsumerGroupSession ) error {
125125 return nil
126126}
You can’t perform that action at this time.
0 commit comments