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 index 624b81ab872b..1479ea6e0ce1 100644 --- 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 index 29af37ddcb66..787c6c8d204d 100644 --- 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"