@Test public void buildFailOnMissingProperties() throws Exception { thrown.expect(IllegalStateException.class); thrown.expectMessage("Missing required properties: bootstrapServers"); KafkaStreamFactory streamFactory = KafkaStreamFactory.newBuilder().build(); }
public static Builder newBuilder() { return new AutoValue_KafkaStreamFactory.Builder() .topic("zipkin") .groupId("zipkin"); }
KafkaStreamFactory implements StreamFactory { public static Builder newBuilder() { return new AutoValue_KafkaStreamFactory.Builder() .topic("zipkin") .groupId("zipkin"); } }
KafkaStreamFactory implements StreamFactory { public static Builder newBuilder() { return new AutoValue_KafkaStreamFactory.Builder() .topic("zipkin") .groupId("zipkin"); } KafkaStreamFactory(); }
KafkaStreamFactory implements StreamFactory { public static Builder newBuilder() { return new AutoValue_KafkaStreamFactory.Builder() .topic("zipkin") .groupId("zipkin"); } KafkaStreamFactory(); static Builder newBuilder(); @Override JavaDStream<byte[]> create(JavaStreamingContext jsc); }
KafkaStreamFactory implements StreamFactory { public static Builder newBuilder() { return new AutoValue_KafkaStreamFactory.Builder() .topic("zipkin") .groupId("zipkin"); } KafkaStreamFactory(); static Builder newBuilder(); @Override JavaDStream<byte[]> create(JavaStreamingContext jsc);  }