This is an automated email from the ASF dual-hosted git repository. cmccabe pushed a commit to branch metashell in repository https://gitbox.apache.org/repos/asf/kafka.git
commit ec2f7e27df62395c98a6a213d9ea469a60957155 Author: Colin P. Mccabe <[email protected]> AuthorDate: Thu Feb 11 09:53:36 2021 -0800 fix comments --- .../src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java | 2 +- shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java | 4 +--- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java index 3aa08dd..ac578fb 100644 --- a/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java +++ b/metadata/src/test/java/org/apache/kafka/metalog/LocalLogManagerTest.java @@ -52,7 +52,7 @@ public class LocalLogManagerTest { } /** - * Test that the local log maanger will claim leadership. + * Test that the local log manager will claim leadership. */ @Test public void testClaimsLeadership() throws Exception { diff --git a/shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java b/shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java index 36f00a4..aa4d4ea 100644 --- a/shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java +++ b/shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java @@ -114,9 +114,7 @@ public final class InteractiveShell implements AutoCloseable { handler.run(Optional.of(this), terminal.writer(), nodeManager); terminal.writer().flush(); } catch (UserInterruptException eof) { - // Handle ths user pressing Control-C. - // TODO: how can we print this on the same line as the prompt like - // bash does? + // Handle the user pressing control-C. terminal.writer().println("^C"); } catch (EndOfFileException eof) { return;
