@Test(expected = NullPointerException.class) public void topicIsNull() { topic(conf); }
@VisibleForTesting static String topic(Configuration conf) { return checkNotNull(stringProperty(conf, TOPIC_NAME), "Property " + TOPIC_NAME + " is not set"); }
KafkaMessageSender { @VisibleForTesting static String topic(Configuration conf) { return checkNotNull(stringProperty(conf, TOPIC_NAME), "Property " + TOPIC_NAME + " is not set"); } }
KafkaMessageSender { @VisibleForTesting static String topic(Configuration conf) { return checkNotNull(stringProperty(conf, TOPIC_NAME), "Property " + TOPIC_NAME + " is not set"); } KafkaMessageSender(Configuration conf); @VisibleForTesting  KafkaMessageSender(String topic, KafkaProducer<Long, byte[]> producer); }
KafkaMessageSender { @VisibleForTesting static String topic(Configuration conf) { return checkNotNull(stringProperty(conf, TOPIC_NAME), "Property " + TOPIC_NAME + " is not set"); } KafkaMessageSender(Configuration conf); @VisibleForTesting  KafkaMessageSender(String topic, KafkaProducer<Long, byte[]> producer); void send(KafkaMessage kafkaMessage); }
KafkaMessageSender { @VisibleForTesting static String topic(Configuration conf) { return checkNotNull(stringProperty(conf, TOPIC_NAME), "Property " + TOPIC_NAME + " is not set"); } KafkaMessageSender(Configuration conf); @VisibleForTesting  KafkaMessageSender(String topic, KafkaProducer<Long, byte[]> producer); void send(KafkaMessage kafkaMessage);  }