@Test public void testGetFetcherMinBytes() { KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "host1", "", "", "", null); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_FETCHER_MIN_BYTES_DEFAULT, config.getKafkaFetcherMinBytes()); config = getStreamConfig("topic", "host1", "", "", "", ""); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_FETCHER_MIN_BYTES_DEFAULT, config.getKafkaFetcherMinBytes()); config = getStreamConfig("topic", "host1", "", "", "", "bad value"); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_FETCHER_MIN_BYTES_DEFAULT, config.getKafkaFetcherMinBytes()); config = getStreamConfig("topic", "host1", "", "", "", "100"); Assert.assertEquals(100, config.getKafkaFetcherMinBytes()); }
public int getKafkaFetcherMinBytes() { return _kafkaFetcherMinBytes; }
KafkaPartitionLevelStreamConfig { public int getKafkaFetcherMinBytes() { return _kafkaFetcherMinBytes; } }
KafkaPartitionLevelStreamConfig { public int getKafkaFetcherMinBytes() { return _kafkaFetcherMinBytes; } KafkaPartitionLevelStreamConfig(StreamConfig streamConfig); }
KafkaPartitionLevelStreamConfig { public int getKafkaFetcherMinBytes() { return _kafkaFetcherMinBytes; } KafkaPartitionLevelStreamConfig(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(); }
KafkaPartitionLevelStreamConfig { public int getKafkaFetcherMinBytes() { return _kafkaFetcherMinBytes; } KafkaPartitionLevelStreamConfig(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();  }