You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/02/02 18:51:20 UTC
kafka git commit: Cherry-pick c97a75d985e42a9d1b1be0352240c45e0b0d2978
Repository: kafka
Updated Branches:
refs/heads/0.9.0 8a2b7763a -> 08ecb5bb0
Cherry-pick c97a75d985e42a9d1b1be0352240c45e0b0d2978
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/08ecb5bb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/08ecb5bb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/08ecb5bb
Branch: refs/heads/0.9.0
Commit: 08ecb5bb0eab2161bda3811c277258aaa07c29e7
Parents: 8a2b776
Author: Guozhang Wang <wa...@gmail.com>
Authored: Tue Feb 2 09:51:12 2016 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Feb 2 09:51:12 2016 -0800
----------------------------------------------------------------------
.../java/org/apache/kafka/clients/consumer/ConsumerConfig.java | 2 +-
docs/upgrade.html | 2 ++
2 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/08ecb5bb/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
----------------------------------------------------------------------
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 9355b08..df192b9 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)
http://git-wip-us.apache.org/repos/asf/kafka/blob/08ecb5bb/docs/upgrade.html
----------------------------------------------------------------------
diff --git a/docs/upgrade.html b/docs/upgrade.html
index 96d1a29..7eb77f9 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -57,6 +57,8 @@
<ul>
<li> The new broker id generation feature can be disable by setting broker.id.generation.enable to false. </li>
<li> 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. </li>
+ <li> MirrorMakerMessageHandler no longer exposes <em>handle(record: MessageAndMetadata[Array[Byte], Array[Byte]])</em> method as it was never called. </li>
+ <li> Default value of configuration parameter fetch.min.bytes for the new consumer is now 1 by default. </li>
</ul>
<h5>Deprecations in 0.9.0.0</h5>