LOG line
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/19ba3003 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/19ba3003 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/19ba3003 Branch: refs/heads/NewKafkaSystemConsumer Commit: 19ba3003078f989400cd9fbefee7c00421bebc6c Parents: 59b3dc1 Author: Boris S <bor...@apache.org> Authored: Fri Aug 31 15:15:04 2018 -0700 Committer: Boris S <bor...@apache.org> Committed: Fri Aug 31 15:20:12 2018 -0700 ---------------------------------------------------------------------- .../org/apache/samza/system/kafka/NewKafkaSystemConsumer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/19ba3003/samza-kafka/src/main/scala/org/apache/samza/system/kafka/NewKafkaSystemConsumer.java ---------------------------------------------------------------------- diff --git a/samza-kafka/src/main/scala/org/apache/samza/system/kafka/NewKafkaSystemConsumer.java b/samza-kafka/src/main/scala/org/apache/samza/system/kafka/NewKafkaSystemConsumer.java index e34812f..aeeadce 100644 --- a/samza-kafka/src/main/scala/org/apache/samza/system/kafka/NewKafkaSystemConsumer.java +++ b/samza-kafka/src/main/scala/org/apache/samza/system/kafka/NewKafkaSystemConsumer.java @@ -348,7 +348,8 @@ public class NewKafkaSystemConsumer<K, V> extends BlockingEnvelopeMap implements } Map<SystemStreamPartition, List<IncomingMessageEnvelope>> res = super.poll(systemStreamPartitions, timeout); - LOG.info("=============================>. Res in POLL:" + res.toString()); + LOG.info("=============================>. Res for " + systemStreamPartitions); + LOG.info("=============================>. Res:" + res.toString()); return res; }
