Update 2.0

Fix :)

internal/usecases/consume/handlemessage.go

@@ -72,7 +72,7 @@ func (s *Service) HandleMessage(msg *brokeradapter.Message) {
 	}
 
 	// Add type indicator to result from database
-	var res int
+	var res interface{}
 	json.Unmarshal(*result, &res)
 	resultMsgMap := make(map[string]interface{})
 	resultMsgMap["type"] = "query_result"