You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2018/09/26 00:23:27 UTC
[28/29] samza git commit: added job name to test
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 <bo...@apache.org>
Authored: Tue Sep 25 16:25:27 2018 -0700
Committer: Boris S <bo...@apache.org>
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 =