@Test
public void testOutputToSolr_noUrlOrZkConnectString() throws Exception {

  LOG.info("testOutputToSolr_noUrlOrZkConnectString()");
  expectedException.expect(Exception.class);
  expectedException.expectMessage("For solr output, either url or zk_connect_string property need to be set");
  Map<String, Object> config = new HashMap<String, Object>();
  config.put("workers", "3");
  config.put("collection", "some collection");
  outputSolr.loadConfig(config);
  outputSolr.init();
}