You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jq...@apache.org on 2017/05/21 21:34:25 UTC

kafka git commit: KAFKA-4208; Add record headers upgrade doc

Repository: kafka
Updated Branches:
  refs/heads/trunk 8b04d8ba0 -> 1c7fdd284


KAFKA-4208; Add record headers upgrade doc

Update upgrade.html

Raising this now, as KIP-118 is pulled from release as such submitting this without java 8 changes.

As per remaining review comment from https://github.com/apache/kafka/pull/2772, updating the upgrade notes.

Author: Michael André Pearce <mi...@me.com>
Author: Michael Andre Pearce <Mi...@me.com>

Reviewers: Jiangjie Qin <be...@gmail.com>, Ismael Juma <is...@juma.me.uk>

Closes #2991 from michaelandrepearce/KIP-82


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1c7fdd28
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1c7fdd28
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1c7fdd28

Branch: refs/heads/trunk
Commit: 1c7fdd2843482beab4039fbb487a8d7d53800292
Parents: 8b04d8b
Author: Michael André Pearce <mi...@me.com>
Authored: Sun May 21 14:34:19 2017 -0700
Committer: Jiangjie Qin <be...@gmail.com>
Committed: Sun May 21 14:34:19 2017 -0700

----------------------------------------------------------------------
 docs/upgrade.html | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1c7fdd28/docs/upgrade.html
----------------------------------------------------------------------
diff --git a/docs/upgrade.html b/docs/upgrade.html
index 9c0ffdf..a2d83a6 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -69,12 +69,17 @@
         producer's <code>batch.size</code> configuration.</li>
     <li>GC log rotation is enabled by default, see KAFKA-3754 for details.</li>
     <li>Deprecated constructors of MetricName and Cluster classes have been removed.</li>
+    <li>Added user headers support through a new Headers interface providing user headers read and write access.</li>
+    <li>ProducerRecord and ConsumerRecord expose the new Headers API via <code>Headers headers()</code> method call.</li>
+    <li>ExtendedSerializer and ExtendedDeserializer interfaces are introduced to support serialization and deserialization for headers. Headers will be ignored if the configured serializer and deserializer are not the above classes.</li>
 </ul>
 
 <h5><a id="upgrade_1100_new_protocols" href="#upgrade_1100_new_protocols">New Protocol Versions</a></h5>
 <ul>
     <li> <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-107%3A+Add+purgeDataBefore()+API+in+AdminClient">KIP-107</a>: FetchRequest v5 introduces a partition-level <code>log_start_offset</code> field. </li>
     <li> <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-107%3A+Add+purgeDataBefore()+API+in+AdminClient">KIP-107</a>: FetchResponse v5 introduces a partition-level <code>log_start_offset</code> field. </li>
+    <li> <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers">KIP-82</a>: ProduceRequest v3 introduces an array of <code>header</code> in the message protocol, containing <code>key</code> field and <code>value</code> field.</li>
+    <li> <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers">KIP-82</a>: FetchResponse v5 introduces an array of <code>header</code> in the message protocol, containing <code>key</code> field and <code>value</code> field.</li>
 </ul>
 
 <h4><a id="upgrade_10_2_0" href="#upgrade_10_2_0">Upgrading from 0.8.x, 0.9.x, 0.10.0.x or 0.10.1.x to 0.10.2.0</a></h4>