You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/10/25 15:31:49 UTC
kafka git commit: HOTFIX: Remove sysout logging
Repository: kafka
Updated Branches:
refs/heads/0.11.0 472c8974f -> 176ff0d69
HOTFIX: Remove sysout logging
Author: Guozhang Wang <wa...@gmail.com>
Reviewers: Damian Guy <da...@gmail.com>, Xavier Léauté <xa...@confluent.io>
Closes #4130 from guozhangwang/KHotfix-0110-remove-logging
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/176ff0d6
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/176ff0d6
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/176ff0d6
Branch: refs/heads/0.11.0
Commit: 176ff0d6924f401bff9bf6735ad35020d249a233
Parents: 472c897
Author: Guozhang Wang <wa...@gmail.com>
Authored: Wed Oct 25 08:31:46 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Oct 25 08:31:46 2017 -0700
----------------------------------------------------------------------
.../kafka/streams/processor/internals/RecordCollectorImpl.java | 2 --
.../org/apache/kafka/streams/processor/internals/RecordQueue.java | 3 ---
2 files changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/176ff0d6/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
index 02b07f6..20f5b48 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
@@ -117,8 +117,6 @@ public class RecordCollectorImpl implements RecordCollector {
}
});
- System.out.println("Send record " + serializedRecord);
-
return;
} catch (final TimeoutException e) {
if (attempt == MAX_SEND_ATTEMPTS) {
http://git-wip-us.apache.org/repos/asf/kafka/blob/176ff0d6/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java
index 61d8205..0902614 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java
@@ -82,9 +82,6 @@ public class RecordQueue {
public int addRawRecords(Iterable<ConsumerRecord<byte[], byte[]>> rawRecords) {
for (ConsumerRecord<byte[], byte[]> rawRecord : rawRecords) {
ConsumerRecord<Object, Object> record = recordDeserializer.deserialize(rawRecord);
-
- System.out.println("Got record " + record);
-
long timestamp = timestampExtractor.extract(record, timeTracker.get());
log.trace("Source node {} extracted timestamp {} for record {}", source.name(), timestamp, record);