diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java index 9355b08acf1..df192b9012e 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java @@ -226,7 +226,7 @@ public class ConsumerConfig extends AbstractConfig { CommonClientConfigs.RECEIVE_BUFFER_DOC) .define(FETCH_MIN_BYTES_CONFIG, Type.INT, - 1024, + 1, atLeast(0), Importance.HIGH, FETCH_MIN_BYTES_DOC) diff --git a/docs/upgrade.html b/docs/upgrade.html index 3244a2c6718..ba59cc0d475 100644 --- a/docs/upgrade.html +++ b/docs/upgrade.html @@ -58,6 +58,7 @@
  • The new broker id generation feature can be disable by setting broker.id.generation.enable to false.
  • Configuration parameter log.cleaner.enable is now true by default. This means topics with a cleanup.policy=compact will now be compacted by default, and 128 MB of heap will be allocated to the cleaner process via log.cleaner.dedupe.buffer.size. You may want to review log.cleaner.dedupe.buffer.size and the other log.cleaner configuration values based on your usage of compacted topics.
  • MirrorMakerMessageHandler no longer exposes handle(record: MessageAndMetadata[Array[Byte], Array[Byte]]) method as it was never called.
  • +
  • Default value of configuration parameter fetch.min.bytes for the new consumer is now 1 by default.
  • Deprecations in 0.9.0.0