added License message
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5120740a Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/5120740a Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/5120740a Branch: refs/heads/NewKafkaSystemConsumer Commit: 5120740aa04ab5dcb24ffd3ff5f7dc5114a32653 Parents: 32c9282 Author: Boris S <[email protected]> Authored: Wed Sep 12 15:58:55 2018 -0700 Committer: Boris S <[email protected]> Committed: Wed Sep 12 15:58:55 2018 -0700 ---------------------------------------------------------------------- .../samza/system/kafka/KafkaSystemConsumer.java | 2 -- .../clients/consumer/TestKafkaConsumerConfig.java | 16 ++++++++++++++++ 2 files changed, 16 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/5120740a/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.java ---------------------------------------------------------------------- diff --git a/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.java b/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.java index 9cdfce1..9101a89 100644 --- a/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.java +++ b/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.java @@ -363,12 +363,10 @@ public class KafkaSystemConsumer<K, V> extends BlockingEnvelopeMap implements Sy } boolean needsMoreMessages(SystemStreamPartition ssp) { - if (LOG.isDebugEnabled()) { LOG.debug("needsMoreMessages from following SSP: {}. fetchLimitByBytes enabled={}; messagesSizeInQueue={};" + "(limit={}); messagesNumInQueue={}(limit={};", ssp, fetchThresholdBytesEnabled, getMessagesSizeInQueue(ssp), perPartitionFetchThresholdBytes, getNumMessagesInQueue(ssp), perPartitionFetchThreshold); - } if (fetchThresholdBytesEnabled) { return getMessagesSizeInQueue(ssp) < perPartitionFetchThresholdBytes; http://git-wip-us.apache.org/repos/asf/samza/blob/5120740a/samza-kafka/src/test/java/org/apache/kafka/clients/consumer/TestKafkaConsumerConfig.java ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/java/org/apache/kafka/clients/consumer/TestKafkaConsumerConfig.java b/samza-kafka/src/test/java/org/apache/kafka/clients/consumer/TestKafkaConsumerConfig.java index ee300d0..264098b 100644 --- a/samza-kafka/src/test/java/org/apache/kafka/clients/consumer/TestKafkaConsumerConfig.java +++ b/samza-kafka/src/test/java/org/apache/kafka/clients/consumer/TestKafkaConsumerConfig.java @@ -1,3 +1,19 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.kafka.clients.consumer; import java.util.Collections;
