Mute debugging output

Author: kkdai

sender/cassandra.go

@@ -31,18 +31,8 @@ func NewCassandra(dbConfig DBConfig) *Cassandra {
 //InsertKV :
 func (c *Cassandra) InsertKV(table, key, value string) error {
 	qStr := fmt.Sprintf("INSERT INTO %s (uuid, key, value) VALUES (?, ?, ?)", table)
-	log.Println("CQL:", qStr)
 	if err := c.Session.Query(qStr, cassandra.TimeUUID(), key, value).Exec(); err != nil {
 		log.Fatal(err)
 	}
-	iter2 := c.Session.Query("SELECT key,value  FROM raw_record").Iter()
-	for iter2.Scan(&key, &value) {
-		fmt.Println("kafka:", key, value)
-	}
-
-	err := iter2.Close()
-	if err != nil {
-		log.Fatal(err)
-	}
-	return err
+	return nil
 }