func init() {
	log.SetFormatter(&log.TextFormatter{
		TimestampFormat: "2006/01/02 - 15:04:05",
		FullTimestamp:   true,
	})
	log.SetLevel(log.InfoLevel)
}
TODO: refactoring to move and log format
package main
import (
	"os"
	"os/signal"
	"time"
	"github.com/Shopify/sarama"
	jsoniter "github.com/json-iterator/go"
	log "github.com/sirupsen/logrus"
	rbt "github.com/emirpasic/gods/trees/redblacktree"
	"github.com/emirpasic/gods/utils"
)