feat: include error message in DESCRIBE CONNECTOR (MINOR) (#3289)

confluentinc · Sep 3, 2019 · 458f1d8 · 458f1d8
1 parent 04435d7
commit 458f1d8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/ksql-cli/src/main/java/io/confluent/ksql/cli/console/Console.java b/ksql-cli/src/main/java/io/confluent/ksql/cli/console/Console.java
@@ -667,6 +667,9 @@ private void printConnectorDescription(final ConnectorDescription description) {
     writer().println(String.format("%-20s : %s", "Type", description.getStatus().type()));
     writer().println(String.format("%-20s : %s", "State", status.connector().state()));
     writer().println(String.format("%-20s : %s", "WorkerId", status.connector().workerId()));
+    if (!status.connector().trace().isEmpty()) {
+      writer().println(String.format("%-20s : %s", "Trace", status.connector().trace()));
+    }
     writer().println();
 
     if (!status.tasks().isEmpty()) {

diff --git a/ksql-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java b/ksql-cli/src/test/java/io/confluent/ksql/cli/console/ConsoleTest.java
@@ -619,6 +619,7 @@ public void testPrintConnectorDescription() throws IOException {
           + "Type                 : source\n"
           + "State                : state\n"
           + "WorkerId             : worker\n"
+          + "Trace                : msg\n"
           + "\n"
           + " Task ID | State | Error Trace \n"
           + "-------------------------------\n"