|
...
|
...
|
@@ -53,6 +53,8 @@ func (c *MessageConsumer) ConsumeClaim(groupSession sarama.ConsumerGroupSession, |
|
|
|
err error
|
|
|
|
)
|
|
|
|
for message := range groupClaim.Messages() {
|
|
|
|
logs.Debug("Done Message claimed: timestamp = %v, topic = %s offset = %v value = %v \n",
|
|
|
|
message.Timestamp, message.Topic, message.Offset, string(message.Value))
|
|
|
|
if topicHandle, err = c.FindTopichandle(groupClaim.Topic()); err != nil {
|
|
|
|
logs.Error("FindTopichandle err:%s \n", err)
|
|
|
|
continue
|
...
|
...
|
|
