| heron_kafka_bolts_test_dep = [ |
| "//contrib/bolts/kafka/src/java:heron-kafka-bolt-java", |
| "//heron/api/src/java:api-java-low-level", |
| "//heron/common/src/java:basics-java", |
| "//heron/common/src/java:config-java", |
| "//third_party/java:junit4", |
| "@org_apache_kafka_kafka_clients//jar", |
| "@org_mockito_mockito_all//jar", |
| ] |
| |
| java_test( |
| name = "KafkaBoltTest", |
| srcs = ["org/apache/heron/bolts/kafka/KafkaBoltTest.java"], |
| test_class = "org.apache.heron.bolts.kafka.KafkaBoltTest", |
| deps = heron_kafka_bolts_test_dep, |
| ) |
| |
| java_test( |
| name = "DefaultKafkaProducerFactoryTest", |
| srcs = ["org/apache/heron/bolts/kafka/DefaultKafkaProducerFactoryTest.java"], |
| test_class = "org.apache.heron.bolts.kafka.DefaultKafkaProducerFactoryTest", |
| deps = heron_kafka_bolts_test_dep, |
| ) |
