added job name to test
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/da39af72 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/da39af72 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/da39af72 Branch: refs/heads/NewKafkaSystemConsumer Commit: da39af728993a83538af6957e9c8ab09cfba1ccd Parents: 190a399 Author: Boris S <[email protected]> Authored: Tue Sep 25 16:25:27 2018 -0700 Committer: Boris S <[email protected]> Committed: Tue Sep 25 16:25:27 2018 -0700 ---------------------------------------------------------------------- .../org/apache/samza/system/kafka/TestKafkaSystemConsumer.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/da39af72/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java index 933558c..5791545 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java @@ -29,6 +29,7 @@ import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.common.serialization.ByteArraySerializer; import org.apache.samza.Partition; import org.apache.samza.config.Config; +import org.apache.samza.config.JobConfig; import org.apache.samza.config.KafkaConfig; import org.apache.samza.config.KafkaConsumerConfig; import org.apache.samza.config.MapConfig; @@ -57,6 +58,7 @@ public class TestKafkaSystemConsumer { map.put(String.format(KafkaConfig.CONSUMER_FETCH_THRESHOLD_BYTES(), TEST_SYSTEM), fetchBytes); map.put(String.format("systems.%s.consumer.%s", TEST_SYSTEM, ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG), BOOTSTRAP_SERVER); + map.put(JobConfig.JOB_NAME(), "jobName"); Config config = new MapConfig(map); KafkaConsumerConfig consumerConfig =
