@Test public void testGetFetcherSize() { KafkaLowLevelStreamConfig config = getStreamConfig("topic", "host1", "", "", "",null); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_BUFFER_SIZE_DEFAULT, config.getKafkaFetcherSizeBytes()); config = getStreamConfig("topic", "host1", "100", "", "", null); Assert.assertEquals(100, config.getKafkaFetcherSizeBytes()); config = getStreamConfig("topic", "host1", "100", "", "bad value", null); Assert.assertEquals(100, config.getKafkaFetcherSizeBytes()); config = getStreamConfig("topic", "host1", "100", "", "200", null); Assert.assertEquals(200, config.getKafkaFetcherSizeBytes()); }
public int getKafkaFetcherSizeBytes() { return _kafkaFetcherSizeBytes; }
KafkaLowLevelStreamConfig { public int getKafkaFetcherSizeBytes() { return _kafkaFetcherSizeBytes; } }
KafkaLowLevelStreamConfig { public int getKafkaFetcherSizeBytes() { return _kafkaFetcherSizeBytes; } KafkaLowLevelStreamConfig(StreamConfig streamConfig); }
KafkaLowLevelStreamConfig { public int getKafkaFetcherSizeBytes() { return _kafkaFetcherSizeBytes; } KafkaLowLevelStreamConfig(StreamConfig streamConfig); String getKafkaTopicName(); String getBootstrapHosts(); int getKafkaBufferSize(); int getKafkaSocketTimeout(); int getKafkaFetcherSizeBytes(); int getKafkaFetcherMinBytes(); @Override String toString(); @Override boolean equals(Object o); @Override int hashCode(); }
KafkaLowLevelStreamConfig { public int getKafkaFetcherSizeBytes() { return _kafkaFetcherSizeBytes; } KafkaLowLevelStreamConfig(StreamConfig streamConfig); String getKafkaTopicName(); String getBootstrapHosts(); int getKafkaBufferSize(); int getKafkaSocketTimeout(); int getKafkaFetcherSizeBytes(); int getKafkaFetcherMinBytes(); @Override String toString(); @Override boolean equals(Object o); @Override int hashCode();  }