Repository: kafka Updated Branches: refs/heads/0.11.0 472c8974f -> 176ff0d69
HOTFIX: Remove sysout logging Author: Guozhang Wang <[email protected]> Reviewers: Damian Guy <[email protected]>, Xavier Léauté <[email protected]> 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 <[email protected]> Authored: Wed Oct 25 08:31:46 2017 -0700 Committer: Guozhang Wang <[email protected]> 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);
