You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/02/11 17:57:16 UTC
[kafka] 06/06: fix comments
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 <cm...@confluent.io>
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;