root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

removed stray println

This commit is contained in:
Geoff Anderson 2015-06-15 18:51:58 -07:00
parent b15b24f177
commit e6a41f1c9a
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
clients/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java
View File

@ -136,9 +136,6 @@ public class VerifiableProducer {
try { try {
Namespace res; Namespace res;
res = parser.parseArgs(args); res = parser.parseArgs(args);
System.out.println(res);
System.out.println(res.getString("brokerList"));
int maxMessages = res.getInt("maxMessages"); int maxMessages = res.getInt("maxMessages");
String topic = res.getString("topic"); String topic = res.getString("topic");

2
tests/kafkatest/services/verifiable_producer.py
View File

@ -38,7 +38,7 @@ class VerifiableProducer(BackgroundThreadService):
def _worker(self, idx, node): def _worker(self, idx, node):
cmd = self.start_cmd cmd = self.start_cmd
self.logger.debug("Verbose producer %d command: %s" % (idx, cmd)) self.logger.debug("VerifiableProducer %d command: %s" % (idx, cmd))
for line in node.account.ssh_capture(cmd): for line in node.account.ssh_capture(cmd):
line = line.strip() line = line.strip()