fix(topic): log response body (#483)

Author: Enda

pkg/cmd/kafka/topic/create/create.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/ioutil"
 
 	"github.com/AlecAivazis/survey/v2"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
@@ -161,6 +162,12 @@ func runCmd(opts *Options) error {
 	createTopicReq = createTopicReq.NewTopicInput(topicInput)
 
 	response, httpRes, topicErr := createTopicReq.Execute()
+	bodyBytes, err := ioutil.ReadAll(httpRes.Body)
+	if err != nil {
+		logger.Debug("Couls not read response body")
+	} else {
+		logger.Debug("Response Body:", string(bodyBytes))
+	}
 	if topicErr.Error() != "" {
 		if httpRes == nil {
 			return topicErr

pkg/cmd/kafka/topic/delete/delete.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"io/ioutil"
 
 	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
 
@@ -124,6 +125,12 @@ func runCmd(opts *Options) error {
 	// perform delete topic API request
 	_, httpRes, topicErr := api.GetTopic(context.Background(), opts.topicName).
 		Execute()
+	bodyBytes, err := ioutil.ReadAll(httpRes.Body)
+	if err != nil {
+		logger.Debug("Could not read response body")
+	} else {
+		logger.Debug("Response Body:", string(bodyBytes))
+	}
 
 	if topicErr.Error() != "" {
 		if httpRes == nil {

pkg/cmd/kafka/topic/describe/describe.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/ioutil"
 
 	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/cmdutil"
@@ -117,10 +118,21 @@ func runCmd(opts *Options) error {
 		return err
 	}
 
+	logger, err := opts.Logger()
+	if err != nil {
+		return err
+	}
+
 	// fetch the topic
 	topicResponse, httpRes, topicErr := api.
 		GetTopic(context.Background(), opts.topicName).
 		Execute()
+	bodyBytes, err := ioutil.ReadAll(httpRes.Body)
+	if err != nil {
+		logger.Debug("Could not read response body")
+	} else {
+		logger.Debug("Response Body:", string(bodyBytes))
+	}
 
 	if topicErr.Error() != "" {
 		if httpRes == nil {

pkg/cmd/kafka/topic/list/list.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/ioutil"
 
 	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/cmd/flag"
@@ -101,6 +102,12 @@ func runCmd(opts *Options) error {
 
 	a := api.GetTopicsList(context.Background())
 	topicData, httpRes, topicErr := a.Execute()
+	bodyBytes, err := ioutil.ReadAll(httpRes.Body)
+	if err != nil {
+		logger.Debug("Couls not read response body")
+	} else {
+		logger.Debug("Response Body:", string(bodyBytes))
+	}
 
 	if topicErr.Error() != "" {
 		if httpRes == nil {

pkg/cmd/kafka/topic/update/update.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/ioutil"
 
 	"github.com/AlecAivazis/survey/v2"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
@@ -263,6 +264,12 @@ func runCmd(opts *Options) error {
 
 	// update the topic
 	response, httpRes, topicErr := updateTopicReq.Execute()
+	bodyBytes, err := ioutil.ReadAll(httpRes.Body)
+	if err != nil {
+		logger.Debug("Could not read response body")
+	} else {
+		logger.Debug("Response Body:", string(bodyBytes))
+	}
 	// handle error
 	if topicErr.Error() != "" {
 		if httpRes == nil {