SEBA-766-Err-handling-for-exporter
Change-Id: I9b7b775ec8d2b335720b315d470ab83286bf0aa3
diff --git a/topic-listener.go b/topic-listener.go
index 9b0f2dc..47003e8 100644
--- a/topic-listener.go
+++ b/topic-listener.go
@@ -28,8 +28,8 @@
defer wg.Done()
consumer, err := master.ConsumePartition(*topic, 0, sarama.OffsetOldest)
if err != nil {
- logger.Error("topicListener panic")
- panic(err)
+ logger.Error("topicListener panic, topic=[%s]: %s", *topic, err.Error())
+ return
}
signals := make(chan os.Signal, 1)
signal.Notify(signals, os.Interrupt)
@@ -38,9 +38,9 @@
for {
select {
case err := <-consumer.Errors():
- logger.Error("%s", err)
+ logger.Error("Consumer error: %s", err.Err)
case msg := <-consumer.Messages():
- logger.Debug("Message on %s: %s", *topic, string(msg.Value))
+ logger.Debug("Got message on topic=[%s]: %s", *topic, string(msg.Value))
export(topic, msg.Value)
case <-signals:
logger.Warn("Interrupt is detected")