Use value instread of body to make it similar to rdkafka

blep-ai · Jun 5, 2018 · 434dac5 · 434dac5
1 parent 3e9fc05
commit 434dac5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/k2ws/k2ws.go b/k2ws/k2ws.go
@@ -157,11 +157,11 @@ func (k2ws *K2WS) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 						}
 						var msg string
 						if kcfg.MessageType == "json" {
-							msg = fmt.Sprintf("{\"headers\":{%s},\"body\":%s}", headers, string(e.Value))
+							msg = fmt.Sprintf("{\"headers\":{%s},\"value\":%s}", headers, string(e.Value))
 						} else {
 							val, err := json.Marshal(string(e.Value))
 							if err == nil {
-								msg = fmt.Sprintf("{\"headers\":{%s},\"body\":%s}", headers, string(val))
+								msg = fmt.Sprintf("{\"headers\":{%s},\"value\":%s}", headers, string(val))
 							} else {
 								msg = fmt.Sprintf("{\"headers\":{%s}}", headers)
 							}