OutputSolr extends Output { @Override public void init() throws Exception { super.init(); initParams(); setupSecurity(); createOutgoingBuffer(); createSolrWorkers(); }  @Override void init(); @Override void write(Map<String, Object> jsonObj, InputMarker inputMarker); void flush(); @Override void setDrain(boolean drain); @Override long getPendingCount(); @Override void close(); @Override String getShortDescription(); @Override void write(String block, InputMarker inputMarker); @Override void copyFile(File inputFile, InputMarker inputMarker);  }
@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(); }