You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2016/02/19 18:27:08 UTC
[3/3] kafka-site git commit: updating docs for 0.9.0.1 release
updating docs for 0.9.0.1 release
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/7f47d190
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/7f47d190
Diff: http://git-wip-us.apache.org/repos/asf/kafka-site/diff/7f47d190
Branch: refs/heads/asf-site
Commit: 7f47d19019122ceed9da8158a7df5063d41e9a49
Parents: 2fb26e0
Author: Jun Rao <ju...@gmail.com>
Authored: Fri Feb 19 09:26:27 2016 -0800
Committer: Jun Rao <ju...@gmail.com>
Committed: Fri Feb 19 09:26:27 2016 -0800
----------------------------------------------------------------------
090/configuration.html | 8 +-
090/connect_config.html | 10 +--
090/consumer_config.html | 2 +-
090/javadoc/allclasses-frame.html | 6 +-
090/javadoc/allclasses-noframe.html | 6 +-
090/javadoc/constant-values.html | 8 +-
090/javadoc/deprecated-list.html | 8 +-
090/javadoc/help-doc.html | 8 +-
090/javadoc/index-all.html | 10 ++-
090/javadoc/index.html | 4 +-
.../clients/consumer/CommitFailedException.html | 8 +-
.../apache/kafka/clients/consumer/Consumer.html | 8 +-
.../kafka/clients/consumer/ConsumerConfig.html | 8 +-
.../consumer/ConsumerRebalanceListener.html | 8 +-
.../kafka/clients/consumer/ConsumerRecord.html | 8 +-
.../kafka/clients/consumer/ConsumerRecords.html | 8 +-
.../consumer/InvalidOffsetException.html | 8 +-
.../kafka/clients/consumer/KafkaConsumer.html | 72 +++++++++++-----
.../kafka/clients/consumer/MockConsumer.html | 8 +-
.../consumer/NoOffsetForPartitionException.html | 8 +-
.../clients/consumer/OffsetAndMetadata.html | 16 ++--
.../clients/consumer/OffsetCommitCallback.html | 8 +-
.../consumer/OffsetOutOfRangeException.html | 8 +-
.../clients/consumer/OffsetResetStrategy.html | 8 +-
.../kafka/clients/consumer/RangeAssignor.html | 8 +-
.../clients/consumer/RoundRobinAssignor.html | 8 +-
.../kafka/clients/consumer/package-frame.html | 6 +-
.../kafka/clients/consumer/package-summary.html | 8 +-
.../kafka/clients/consumer/package-tree.html | 10 +--
.../producer/BufferExhaustedException.html | 8 +-
.../apache/kafka/clients/producer/Callback.html | 8 +-
.../kafka/clients/producer/KafkaProducer.html | 10 +--
.../kafka/clients/producer/MockProducer.html | 8 +-
.../kafka/clients/producer/Partitioner.html | 8 +-
.../apache/kafka/clients/producer/Producer.html | 8 +-
.../kafka/clients/producer/ProducerConfig.html | 8 +-
.../kafka/clients/producer/ProducerRecord.html | 8 +-
.../kafka/clients/producer/RecordMetadata.html | 8 +-
.../kafka/clients/producer/package-frame.html | 6 +-
.../kafka/clients/producer/package-summary.html | 8 +-
.../kafka/clients/producer/package-tree.html | 8 +-
.../org/apache/kafka/common/Cluster.html | 8 +-
.../org/apache/kafka/common/Configurable.html | 8 +-
.../org/apache/kafka/common/KafkaException.html | 8 +-
090/javadoc/org/apache/kafka/common/Metric.html | 8 +-
.../org/apache/kafka/common/MetricName.html | 8 +-
090/javadoc/org/apache/kafka/common/Node.html | 8 +-
.../org/apache/kafka/common/PartitionInfo.html | 8 +-
.../org/apache/kafka/common/TopicPartition.html | 16 ++--
.../kafka/common/errors/ApiException.html | 8 +-
.../common/errors/AuthorizationException.html | 8 +-
.../errors/BrokerNotAvailableException.html | 8 +-
.../common/errors/ControllerMovedException.html | 8 +-
.../common/errors/CorruptRecordException.html | 8 +-
.../common/errors/DisconnectException.html | 52 ++++++++++--
.../errors/GroupAuthorizationException.html | 8 +-
.../GroupCoordinatorNotAvailableException.html | 8 +-
.../errors/GroupLoadInProgressException.html | 8 +-
.../errors/IllegalGenerationException.html | 8 +-
.../kafka/common/errors/InterruptException.html | 8 +-
.../common/errors/InvalidMetadataException.html | 8 +-
.../errors/InvalidRequiredAcksException.html | 8 +-
.../common/errors/InvalidTopicException.html | 8 +-
.../errors/LeaderNotAvailableException.html | 8 +-
.../kafka/common/errors/NetworkException.html | 8 +-
.../errors/NotCoordinatorForGroupException.html | 8 +-
.../NotEnoughReplicasAfterAppendException.html | 8 +-
.../errors/NotEnoughReplicasException.html | 8 +-
.../errors/NotLeaderForPartitionException.html | 8 +-
.../common/errors/OffsetMetadataTooLarge.html | 8 +-
.../errors/RebalanceInProgressException.html | 8 +-
.../errors/RecordBatchTooLargeException.html | 8 +-
.../common/errors/RecordTooLargeException.html | 8 +-
.../kafka/common/errors/RetriableException.html | 8 +-
.../common/errors/SerializationException.html | 8 +-
.../kafka/common/errors/TimeoutException.html | 8 +-
.../errors/TopicAuthorizationException.html | 8 +-
.../common/errors/UnknownMemberIdException.html | 8 +-
.../common/errors/UnknownServerException.html | 8 +-
.../UnknownTopicOrPartitionException.html | 8 +-
.../kafka/common/errors/WakeupException.html | 8 +-
.../kafka/common/errors/package-frame.html | 6 +-
.../kafka/common/errors/package-summary.html | 8 +-
.../kafka/common/errors/package-tree.html | 8 +-
.../org/apache/kafka/common/package-frame.html | 6 +-
.../apache/kafka/common/package-summary.html | 8 +-
.../org/apache/kafka/common/package-tree.html | 10 +--
.../serialization/ByteArrayDeserializer.html | 8 +-
.../serialization/ByteArraySerializer.html | 8 +-
.../common/serialization/Deserializer.html | 8 +-
.../serialization/IntegerDeserializer.html | 8 +-
.../common/serialization/IntegerSerializer.html | 8 +-
.../common/serialization/LongDeserializer.html | 8 +-
.../common/serialization/LongSerializer.html | 8 +-
.../kafka/common/serialization/Serializer.html | 8 +-
.../serialization/StringDeserializer.html | 8 +-
.../common/serialization/StringSerializer.html | 8 +-
.../common/serialization/package-frame.html | 6 +-
.../common/serialization/package-summary.html | 8 +-
.../common/serialization/package-tree.html | 8 +-
090/javadoc/overview-frame.html | 6 +-
090/javadoc/overview-summary.html | 10 +--
090/javadoc/overview-tree.html | 12 +--
090/javadoc/serialized-form.html | 56 ++++++++++++-
090/kafka_config.html | 8 +-
090/ops.html | 4 +-
090/quickstart.html | 2 +-
090/security.html | 88 ++++++++++++++++++--
090/upgrade.html | 15 +++-
downloads.html | 21 ++++-
110 files changed, 683 insertions(+), 449 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/configuration.html
----------------------------------------------------------------------
diff --git a/090/configuration.html b/090/configuration.html
index 358431e..b633540 100644
--- a/090/configuration.html
+++ b/090/configuration.html
@@ -247,7 +247,8 @@ The essential old consumer configurations are the following:
<tr>
<td>rebalance.backoff.ms</td>
<td>2000</td>
- <td>Backoff time between retries during rebalance.</td>
+ <td>Backoff time between retries during rebalance. If not set explicitly, the value in zookeeper.sync.time.ms is used.
+ </td>
</tr>
<tr>
<td>refresh.leader.backoff.ms</td>
@@ -271,11 +272,6 @@ The essential old consumer configurations are the following:
<td colspan="1">true</td>
<td>Whether messages from internal topics (such as offsets) should be exposed to the consumer.</td>
</tr>
- <tr>
- <td>partition.assignment.strategy</td>
- <td colspan="1">range</td>
- <td>Select a strategy for assigning partitions to consumer streams. Possible values: range, roundrobin.</td>
- </tr>
<tr>
<td>client.id</td>
<td colspan="1">group id value</td>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/connect_config.html
----------------------------------------------------------------------
diff --git a/090/connect_config.html b/090/connect_config.html
index ef051b9..b9d2a56 100644
--- a/090/connect_config.html
+++ b/090/connect_config.html
@@ -44,19 +44,19 @@
<tr>
<td>sasl.kerberos.service.name</td><td>The Kerberos principal name that Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's config.</td><td>string</td><td>null</td><td></td><td>medium</td></tr>
<tr>
-<td>security.protocol</td><td>Protocol used to communicate with brokers. Currently only PLAINTEXT and SSL are supported.</td><td>string</td><td>PLAINTEXT</td><td></td><td>medium</td></tr>
+<td>security.protocol</td><td>Protocol used to communicate with brokers. Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.</td><td>string</td><td>PLAINTEXT</td><td></td><td>medium</td></tr>
<tr>
<td>send.buffer.bytes</td><td>The size of the TCP send buffer (SO_SNDBUF) to use when sending data.</td><td>int</td><td>131072</td><td>[0,...]</td><td>medium</td></tr>
<tr>
-<td>ssl.enabled.protocols</td><td>The list of protocols enabled for SSL connections. TLSv1.2, TLSv1.1 and TLSv1 are enabled by default.</td><td>list</td><td>[TLSv1.2, TLSv1.1, TLSv1]</td><td></td><td>medium</td></tr>
+<td>ssl.enabled.protocols</td><td>The list of protocols enabled for SSL connections.</td><td>list</td><td>[TLSv1.2, TLSv1.1, TLSv1]</td><td></td><td>medium</td></tr>
<tr>
-<td>ssl.keystore.type</td><td>The file format of the key store file. This is optional for client. Default value is JKS</td><td>string</td><td>JKS</td><td></td><td>medium</td></tr>
+<td>ssl.keystore.type</td><td>The file format of the key store file. This is optional for client.</td><td>string</td><td>JKS</td><td></td><td>medium</td></tr>
<tr>
<td>ssl.protocol</td><td>The SSL protocol used to generate the SSLContext. Default setting is TLS, which is fine for most cases. Allowed values in recent JVMs are TLS, TLSv1.1 and TLSv1.2. SSL, SSLv2 and SSLv3 may be supported in older JVMs, but their usage is discouraged due to known security vulnerabilities.</td><td>string</td><td>TLS</td><td></td><td>medium</td></tr>
<tr>
<td>ssl.provider</td><td>The name of the security provider used for SSL connections. Default value is the default security provider of the JVM.</td><td>string</td><td>null</td><td></td><td>medium</td></tr>
<tr>
-<td>ssl.truststore.type</td><td>The file format of the trust store file. Default value is JKS.</td><td>string</td><td>JKS</td><td></td><td>medium</td></tr>
+<td>ssl.truststore.type</td><td>The file format of the trust store file.</td><td>string</td><td>JKS</td><td></td><td>medium</td></tr>
<tr>
<td>worker.sync.timeout.ms</td><td>When the worker is out of sync with other workers and needs to resynchronize configurations, wait up to this amount of time before giving up, leaving the group, and waiting a backoff period before rejoining.</td><td>int</td><td>3000</td><td></td><td>medium</td></tr>
<tr>
@@ -88,7 +88,7 @@
<tr>
<td>retry.backoff.ms</td><td>The amount of time to wait before attempting to retry a failed fetch request to a given topic partition. This avoids repeated fetching-and-failing in a tight loop.</td><td>long</td><td>100</td><td>[0,...]</td><td>low</td></tr>
<tr>
-<td>sasl.kerberos.kinit.cmd</td><td>Kerberos kinit command path. Default is /usr/bin/kinit</td><td>string</td><td>/usr/bin/kinit</td><td></td><td>low</td></tr>
+<td>sasl.kerberos.kinit.cmd</td><td>Kerberos kinit command path.</td><td>string</td><td>/usr/bin/kinit</td><td></td><td>low</td></tr>
<tr>
<td>sasl.kerberos.min.time.before.relogin</td><td>Login thread sleep time between refresh attempts.</td><td>long</td><td>60000</td><td></td><td>low</td></tr>
<tr>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/consumer_config.html
----------------------------------------------------------------------
diff --git a/090/consumer_config.html b/090/consumer_config.html
index 5a2bf9c..942dc46 100644
--- a/090/consumer_config.html
+++ b/090/consumer_config.html
@@ -14,7 +14,7 @@
<tr>
<td>value.deserializer</td><td>Deserializer class for value that implements the <code>Deserializer</code> interface.</td><td>class</td><td></td><td></td><td>high</td></tr>
<tr>
-<td>fetch.min.bytes</td><td>The minimum amount of data the server should return for a fetch request. If insufficient data is available the request will wait for that much data to accumulate before answering the request. The default setting of 1 byte means that fetch requests are answered as soon as a single byte of data is available or the fetch request times out waiting for data to arrive. Setting this to something greater than 1 will cause the server to wait for larger amounts of data to accumulate which can improve server throughput a bit at the cost of some additional latency.</td><td>int</td><td>1024</td><td>[0,...]</td><td>high</td></tr>
+<td>fetch.min.bytes</td><td>The minimum amount of data the server should return for a fetch request. If insufficient data is available the request will wait for that much data to accumulate before answering the request. The default setting of 1 byte means that fetch requests are answered as soon as a single byte of data is available or the fetch request times out waiting for data to arrive. Setting this to something greater than 1 will cause the server to wait for larger amounts of data to accumulate which can improve server throughput a bit at the cost of some additional latency.</td><td>int</td><td>1</td><td>[0,...]</td><td>high</td></tr>
<tr>
<td>group.id</td><td>A unique string that identifies the consumer group this consumer belongs to. This property is required if the consumer uses either the group management functionality by using <code>subscribe(topic)</code> or the Kafka-based offset management strategy.</td><td>string</td><td>""</td><td></td><td>high</td></tr>
<tr>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/allclasses-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/allclasses-frame.html b/090/javadoc/allclasses-frame.html
index b8ef929..cd2af1e 100644
--- a/090/javadoc/allclasses-frame.html
+++ b/090/javadoc/allclasses-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>All Classes (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:40 CST 2016 -->
+<title>All Classes (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/allclasses-noframe.html
----------------------------------------------------------------------
diff --git a/090/javadoc/allclasses-noframe.html b/090/javadoc/allclasses-noframe.html
index d32d5ec..7260c43 100644
--- a/090/javadoc/allclasses-noframe.html
+++ b/090/javadoc/allclasses-noframe.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>All Classes (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:40 CST 2016 -->
+<title>All Classes (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/constant-values.html
----------------------------------------------------------------------
diff --git a/090/javadoc/constant-values.html b/090/javadoc/constant-values.html
index 0d4f67f..7c185ca 100644
--- a/090/javadoc/constant-values.html
+++ b/090/javadoc/constant-values.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>Constant Field Values (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Constant Field Values (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Constant Field Values (clients 0.9.0.0 API)";
+ parent.document.title="Constant Field Values (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/deprecated-list.html
----------------------------------------------------------------------
diff --git a/090/javadoc/deprecated-list.html b/090/javadoc/deprecated-list.html
index ecbc175..8e688cd 100644
--- a/090/javadoc/deprecated-list.html
+++ b/090/javadoc/deprecated-list.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>Deprecated List (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:40 CST 2016 -->
+<title>Deprecated List (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Deprecated List (clients 0.9.0.0 API)";
+ parent.document.title="Deprecated List (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/help-doc.html
----------------------------------------------------------------------
diff --git a/090/javadoc/help-doc.html b/090/javadoc/help-doc.html
index 10f17da..cab1364 100644
--- a/090/javadoc/help-doc.html
+++ b/090/javadoc/help-doc.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>API Help (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:40 CST 2016 -->
+<title>API Help (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="API Help (clients 0.9.0.0 API)";
+ parent.document.title="API Help (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/index-all.html
----------------------------------------------------------------------
diff --git a/090/javadoc/index-all.html b/090/javadoc/index-all.html
index 70c568c..27e6485 100644
--- a/090/javadoc/index-all.html
+++ b/090/javadoc/index-all.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>Index (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:40 CST 2016 -->
+<title>Index (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="./stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Index (clients 0.9.0.0 API)";
+ parent.document.title="Index (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -616,6 +616,8 @@
<dd> </dd>
<dt><span class="strong"><a href="./org/apache/kafka/common/errors/IllegalGenerationException.html#IllegalGenerationException(java.lang.Throwable)">IllegalGenerationException(Throwable)</a></span> - Constructor for exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></dt>
<dd> </dd>
+<dt><span class="strong"><a href="./org/apache/kafka/common/errors/DisconnectException.html#INSTANCE">INSTANCE</a></span> - Static variable in exception org.apache.kafka.common.errors.<a href="./org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></dt>
+<dd> </dd>
<dt><span class="strong"><a href="./org/apache/kafka/common/PartitionInfo.html#inSyncReplicas()">inSyncReplicas()</a></span> - Method in class org.apache.kafka.common.<a href="./org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a></dt>
<dd>
<div class="block">The subset of the replicas that are in sync, that is caught-up to the leader and ready to take over as leader if
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/index.html
----------------------------------------------------------------------
diff --git a/090/javadoc/index.html b/090/javadoc/index.html
index c9aeb10..a43bbda 100644
--- a/090/javadoc/index.html
+++ b/090/javadoc/index.html
@@ -2,8 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc on Tue Nov 17 18:38:11 PST 2015 -->
-<title>clients 0.9.0.0 API</title>
+<!-- Generated by javadoc on Thu Feb 11 18:46:40 CST 2016 -->
+<title>clients 0.9.0.1 API</title>
<script type="text/javascript">
targetPage = "" + window.location.search;
if (targetPage != "" && targetPage != "undefined")
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html b/090/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html
index a7ed4db..049979f 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>CommitFailedException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>CommitFailedException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="CommitFailedException (clients 0.9.0.0 API)";
+ parent.document.title="CommitFailedException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html b/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html
index 1c3de20..20f23c2 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>Consumer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>Consumer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Consumer (clients 0.9.0.0 API)";
+ parent.document.title="Consumer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
index 34960e0..35e8b95 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerConfig.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>ConsumerConfig (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>ConsumerConfig (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ConsumerConfig (clients 0.9.0.0 API)";
+ parent.document.title="ConsumerConfig (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html
index 6e771db..eea2df4 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>ConsumerRebalanceListener (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>ConsumerRebalanceListener (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ConsumerRebalanceListener (clients 0.9.0.0 API)";
+ parent.document.title="ConsumerRebalanceListener (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html
index 69257f3..7fc2b2b 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>ConsumerRecord (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>ConsumerRecord (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ConsumerRecord (clients 0.9.0.0 API)";
+ parent.document.title="ConsumerRecord (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecords.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecords.html b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecords.html
index d3d7b43..467038d 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecords.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecords.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>ConsumerRecords (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>ConsumerRecords (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ConsumerRecords (clients 0.9.0.0 API)";
+ parent.document.title="ConsumerRecords (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/InvalidOffsetException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/InvalidOffsetException.html b/090/javadoc/org/apache/kafka/clients/consumer/InvalidOffsetException.html
index 5df3d7d..70a54cb 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/InvalidOffsetException.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/InvalidOffsetException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:09 PST 2015 -->
-<title>InvalidOffsetException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>InvalidOffsetException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="InvalidOffsetException (clients 0.9.0.0 API)";
+ parent.document.title="InvalidOffsetException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html b/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
index 3cbad8b..fb2122a 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>KafkaConsumer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>KafkaConsumer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KafkaConsumer (clients 0.9.0.0 API)";
+ parent.document.title="KafkaConsumer (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -186,7 +186,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
props.put("session.timeout.ms", "30000");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
- KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
+ KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("foo", "bar"));
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
@@ -241,23 +241,48 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
props.put("session.timeout.ms", "30000");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
- KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
+ KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("foo", "bar"));
- int commitInterval = 200;
- List<ConsumerRecord<String, String>> buffer = new ArrayList<ConsumerRecord<String, String>>();
+ final int minBatchSize = 200;
+ List<ConsumerRecord<String, String>> buffer = new ArrayList<>();
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {
buffer.add(record);
- if (buffer.size() >= commitInterval) {
- insertIntoDb(buffer);
- consumer.commitSync();
- buffer.clear();
+ }
+ if (buffer.size() >= minBatchSize) {
+ insertIntoDb(buffer);
+ consumer.commitSync();
+ buffer.clear();
+ }
+ }
+ </pre>
+
+ The above example uses <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()"><code>commitSync</code></a> to mark all received messages as committed. In some cases
+ you may wish to have even finer control over which messages have been committed by specifying an offset explicitly.
+ In the example below we commit offset after we finish handling the messages in each partition.
+ <p>
+ <pre>
+ try {
+ while(running) {
+ ConsumerRecords<String, String> records = consumer.poll(Long.MAX_VALUE);
+ for (TopicPartition partition : records.partitions()) {
+ List<ConsumerRecord<String, String>> partitionRecords = records.records(partition);
+ for (ConsumerRecord<String, String> record : partitionRecords) {
+ System.out.println(record.offset() + ": " + record.value());
+ }
+ long lastOffset = partitionRecords.get(partitionRecords.size() - 1).offset();
+ consumer.commitSync(Collections.singletonMap(partition, new OffsetAndMetadata(lastOffset + 1)));
}
}
+ } finally {
+ consumer.close();
}
</pre>
+ <b>Note: The committed offset should always be the offset of the next message that your application will read.</b>
+ Thus, when calling <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)"><code>commitSync(offsets)</code></a> you should add one to the offset of the last message processed.
+
<h4>Subscribing To Specific Partitions</h4>
In the previous examples we subscribed to the topics we were interested in and let Kafka give our particular process
@@ -284,8 +309,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
String topic = "foo";
TopicPartition partition0 = new TopicPartition(topic, 0);
TopicPartition partition1 = new TopicPartition(topic, 1);
- consumer.assign(partition0);
- consumer.assign(partition1);
+ consumer.assign(Arrays.asList(partition0, partition1));
</pre>
The group that the consumer specifies is still used for committing offsets, but now the set of partitions will only
@@ -332,7 +356,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
and <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)"><code>subscribe(Pattern, ConsumerRebalanceListener)</code></a>.
For example, when partitions are taken from a consumer the consumer will want to commit its offset for those partitions by
implementing <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html#onPartitionsRevoked(java.util.Collection)"><code>ConsumerRebalanceListener.onPartitionsRevoked(Collection)</code></a>. When partitions are assigned to a
- consumer, the consumer will want to look up the offset for those new partitions an correctly initialize the consumer
+ consumer, the consumer will want to look up the offset for those new partitions and correctly initialize the consumer
to that position by implementing <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html#onPartitionsAssigned(java.util.Collection)"><code>ConsumerRebalanceListener.onPartitionsAssigned(Collection)</code></a>.
<p>
Another common use for <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><code>ConsumerRebalanceListener</code></a> is to flush any caches the application maintains for
@@ -397,7 +421,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
public void run() {
try {
- consumer.subscribe("topic");
+ consumer.subscribe(Arrays.asList("topic"));
while (!closed.get()) {
ConsumerRecords records = consumer.poll(10000);
// Handle new records
@@ -1003,7 +1027,8 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<p>
This commits offsets to Kafka. The offsets committed using this API will be used on the first fetch after every
rebalance and also on startup. As such, if you need to store offsets in anything other than Kafka, this API
- should not be used.
+ should not be used. The committed offset should be the next message your application will consume,
+ i.e. lastProcessedMessageOffset + 1.
<p>
This is a synchronous commits and will block until either the commit succeeds or an unrecoverable error is
encountered (in which case it is thrown to the caller).</div>
@@ -1071,7 +1096,8 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<p>
This commits offsets to Kafka. The offsets committed using this API will be used on the first fetch after every
rebalance and also on startup. As such, if you need to store offsets in anything other than Kafka, this API
- should not be used.
+ should not be used. The committed offset should be the next message your application will consume,
+ i.e. lastProcessedMessageOffset + 1.
<p>
This is an asynchronous call and will not block. Any errors encountered are either passed to the callback
(if provided) or discarded.</div>
@@ -1208,7 +1234,10 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dt><span class="strong">Throws:</span></dt>
<dd><code><a href="../../../../../org/apache/kafka/common/errors/WakeupException.html" title="class in org.apache.kafka.common.errors">WakeupException</a></code> - if <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#wakeup()"><code>wakeup()</code></a> is called before or while this
function is called</dd>
-<dd><code><a href="../../../../../org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></code> - if not authorized to the specified topic</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)"><code>partitionsFor(String)</code></a></dd></dl>
+<dd><code><a href="../../../../../org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></code> - if not authorized to the specified topic</dd>
+<dd><code><a href="../../../../../org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</a></code> - if the topic metadata could not be fetched before
+ expiration of the configured request timeout</dd>
+<dd><code><a href="../../../../../org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></code> - for any other unrecoverable errors</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)"><code>partitionsFor(String)</code></a></dd></dl>
</li>
</ul>
<a name="listTopics()">
@@ -1226,7 +1255,10 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dt><span class="strong">Returns:</span></dt><dd>The map of topics and its partitions</dd>
<dt><span class="strong">Throws:</span></dt>
<dd><code><a href="../../../../../org/apache/kafka/common/errors/WakeupException.html" title="class in org.apache.kafka.common.errors">WakeupException</a></code> - if <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#wakeup()"><code>wakeup()</code></a> is called before or while this
- function is called</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics()"><code>listTopics()</code></a></dd></dl>
+ function is called</dd>
+<dd><code><a href="../../../../../org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</a></code> - if the topic metadata could not be fetched before
+ expiration of the configured request timeout</dd>
+<dd><code><a href="../../../../../org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></code> - for any other unrecoverable errors</dd><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics()"><code>listTopics()</code></a></dd></dl>
</li>
</ul>
<a name="pause(org.apache.kafka.common.TopicPartition...)">
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html b/090/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html
index cf5503c..a3dec79 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>MockConsumer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>MockConsumer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MockConsumer (clients 0.9.0.0 API)";
+ parent.document.title="MockConsumer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html b/090/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html
index 9f7402e..92d8dac 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>NoOffsetForPartitionException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>NoOffsetForPartitionException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="NoOffsetForPartitionException (clients 0.9.0.0 API)";
+ parent.document.title="NoOffsetForPartitionException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html b/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html
index b76a3f7..e0c653c 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>OffsetAndMetadata (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>OffsetAndMetadata (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="OffsetAndMetadata (clients 0.9.0.0 API)";
+ parent.document.title="OffsetAndMetadata (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -93,13 +93,19 @@
<div class="description">
<ul class="blockList">
<li class="blockList">
+<dl>
+<dt>All Implemented Interfaces:</dt>
+<dd>java.io.Serializable</dd>
+</dl>
<hr>
<br>
<pre>public class <span class="strong">OffsetAndMetadata</span>
-extends java.lang.Object</pre>
+extends java.lang.Object
+implements java.io.Serializable</pre>
<div class="block">The Kafka offset commit API allows users to provide additional metadata (in the form of a string)
when an offset is committed. This can be useful (for example) to store information about which
node made the commit, what time the commit was made, etc.</div>
+<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../serialized-form.html#org.apache.kafka.clients.consumer.OffsetAndMetadata">Serialized Form</a></dd></dl>
</li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html b/090/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html
index be97c24..10eb3b1 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>OffsetCommitCallback (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>OffsetCommitCallback (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="OffsetCommitCallback (clients 0.9.0.0 API)";
+ parent.document.title="OffsetCommitCallback (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html b/090/javadoc/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html
index bdcf3fb..e42e5d9 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>OffsetOutOfRangeException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>OffsetOutOfRangeException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="OffsetOutOfRangeException (clients 0.9.0.0 API)";
+ parent.document.title="OffsetOutOfRangeException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html b/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
index 7307987..3d424dc 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>OffsetResetStrategy (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>OffsetResetStrategy (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="OffsetResetStrategy (clients 0.9.0.0 API)";
+ parent.document.title="OffsetResetStrategy (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html b/090/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
index 8488948..4b3f86a 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/RangeAssignor.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>RangeAssignor (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>RangeAssignor (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="RangeAssignor (clients 0.9.0.0 API)";
+ parent.document.title="RangeAssignor (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/RoundRobinAssignor.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/RoundRobinAssignor.html b/090/javadoc/org/apache/kafka/clients/consumer/RoundRobinAssignor.html
index 7b0eb93..1c388b9 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/RoundRobinAssignor.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/RoundRobinAssignor.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>RoundRobinAssignor (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>RoundRobinAssignor (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="RoundRobinAssignor (clients 0.9.0.0 API)";
+ parent.document.title="RoundRobinAssignor (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html b/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html
index d2f9884..3e13de7 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.consumer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.consumer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/package-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/package-summary.html b/090/javadoc/org/apache/kafka/clients/consumer/package-summary.html
index 6c6f14c..3619b3d 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/package-summary.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/package-summary.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.consumer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.consumer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.clients.consumer (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.clients.consumer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/consumer/package-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/consumer/package-tree.html b/090/javadoc/org/apache/kafka/clients/consumer/package-tree.html
index 7210ce0..f644051 100644
--- a/090/javadoc/org/apache/kafka/clients/consumer/package-tree.html
+++ b/090/javadoc/org/apache/kafka/clients/consumer/package-tree.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.consumer Class Hierarchy (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.consumer Class Hierarchy (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.clients.consumer Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.clients.consumer Class Hierarchy (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -88,7 +88,7 @@
<li type="circle">org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">ConsumerRecords</span></a><K,V> (implements java.lang.Iterable<T>)</li>
<li type="circle">org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">KafkaConsumer</span></a><K,V> (implements org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><K,V>)</li>
<li type="circle">org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">MockConsumer</span></a><K,V> (implements org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer">Consumer</a><K,V>)</li>
-<li type="circle">org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">OffsetAndMetadata</span></a></li>
+<li type="circle">org.apache.kafka.clients.consumer.<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer"><span class="strong">OffsetAndMetadata</span></a> (implements java.io.Serializable)</li>
<li type="circle">java.lang.Throwable (implements java.io.Serializable)
<ul>
<li type="circle">java.lang.Exception
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/BufferExhaustedException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/BufferExhaustedException.html b/090/javadoc/org/apache/kafka/clients/producer/BufferExhaustedException.html
index 06f1c90..c054f24 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/BufferExhaustedException.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/BufferExhaustedException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>BufferExhaustedException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>BufferExhaustedException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="BufferExhaustedException (clients 0.9.0.0 API)";
+ parent.document.title="BufferExhaustedException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/Callback.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/Callback.html b/090/javadoc/org/apache/kafka/clients/producer/Callback.html
index f0f4327..d763710 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/Callback.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/Callback.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Callback (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Callback (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Callback (clients 0.9.0.0 API)";
+ parent.document.title="Callback (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html b/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
index 25b0689..93924df 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>KafkaProducer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>KafkaProducer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KafkaProducer (clients 0.9.0.0 API)";
+ parent.document.title="KafkaProducer (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -120,7 +120,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
- Producer<String, String> producer = new KafkaProducer(props);
+ Producer<String, String> producer = new KafkaProducer<>(props);
for(int i = 0; i < 100; i++)
producer.send(new ProducerRecord<String, String>("my-topic", Integer.toString(i), Integer.toString(i)));
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/MockProducer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/MockProducer.html b/090/javadoc/org/apache/kafka/clients/producer/MockProducer.html
index 1ea145f..cea1fc5 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/MockProducer.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/MockProducer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>MockProducer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>MockProducer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MockProducer (clients 0.9.0.0 API)";
+ parent.document.title="MockProducer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/Partitioner.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/Partitioner.html b/090/javadoc/org/apache/kafka/clients/producer/Partitioner.html
index a40f1fb..69192b6 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/Partitioner.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/Partitioner.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Partitioner (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Partitioner (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Partitioner (clients 0.9.0.0 API)";
+ parent.document.title="Partitioner (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/Producer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/Producer.html b/090/javadoc/org/apache/kafka/clients/producer/Producer.html
index 3d0e610..8323c6c 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/Producer.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/Producer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Producer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Producer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Producer (clients 0.9.0.0 API)";
+ parent.document.title="Producer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html b/090/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
index 274d704..82c05c4 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>ProducerConfig (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>ProducerConfig (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ProducerConfig (clients 0.9.0.0 API)";
+ parent.document.title="ProducerConfig (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html b/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
index a7519bd..606e11a 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>ProducerRecord (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>ProducerRecord (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ProducerRecord (clients 0.9.0.0 API)";
+ parent.document.title="ProducerRecord (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html b/090/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html
index d0bb99e..50eb3b4 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/RecordMetadata.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>RecordMetadata (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>RecordMetadata (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="RecordMetadata (clients 0.9.0.0 API)";
+ parent.document.title="RecordMetadata (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/package-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/package-frame.html b/090/javadoc/org/apache/kafka/clients/producer/package-frame.html
index f4df1ad..d119f50 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/package-frame.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/package-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.producer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.producer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/package-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/package-summary.html b/090/javadoc/org/apache/kafka/clients/producer/package-summary.html
index d99b877..535e33a 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/package-summary.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/package-summary.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.producer (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.producer (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.clients.producer (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.clients.producer (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/clients/producer/package-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/clients/producer/package-tree.html b/090/javadoc/org/apache/kafka/clients/producer/package-tree.html
index 95121fc..f90788d 100644
--- a/090/javadoc/org/apache/kafka/clients/producer/package-tree.html
+++ b/090/javadoc/org/apache/kafka/clients/producer/package-tree.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:11 PST 2015 -->
-<title>org.apache.kafka.clients.producer Class Hierarchy (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>org.apache.kafka.clients.producer Class Hierarchy (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.kafka.clients.producer Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.clients.producer Class Hierarchy (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/Cluster.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/Cluster.html b/090/javadoc/org/apache/kafka/common/Cluster.html
index ad24c66..1d9f36b 100644
--- a/090/javadoc/org/apache/kafka/common/Cluster.html
+++ b/090/javadoc/org/apache/kafka/common/Cluster.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Cluster (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:38 CST 2016 -->
+<title>Cluster (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Cluster (clients 0.9.0.0 API)";
+ parent.document.title="Cluster (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/Configurable.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/Configurable.html b/090/javadoc/org/apache/kafka/common/Configurable.html
index caecfc8..b01bcc1 100644
--- a/090/javadoc/org/apache/kafka/common/Configurable.html
+++ b/090/javadoc/org/apache/kafka/common/Configurable.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Configurable (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Configurable (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Configurable (clients 0.9.0.0 API)";
+ parent.document.title="Configurable (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/KafkaException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/KafkaException.html b/090/javadoc/org/apache/kafka/common/KafkaException.html
index 042e8fa..5db827c 100644
--- a/090/javadoc/org/apache/kafka/common/KafkaException.html
+++ b/090/javadoc/org/apache/kafka/common/KafkaException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>KafkaException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>KafkaException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="KafkaException (clients 0.9.0.0 API)";
+ parent.document.title="KafkaException (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/Metric.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/Metric.html b/090/javadoc/org/apache/kafka/common/Metric.html
index 23381dc..4699239 100644
--- a/090/javadoc/org/apache/kafka/common/Metric.html
+++ b/090/javadoc/org/apache/kafka/common/Metric.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Metric (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Metric (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Metric (clients 0.9.0.0 API)";
+ parent.document.title="Metric (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/MetricName.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/MetricName.html b/090/javadoc/org/apache/kafka/common/MetricName.html
index e8e2b1f..c82480e 100644
--- a/090/javadoc/org/apache/kafka/common/MetricName.html
+++ b/090/javadoc/org/apache/kafka/common/MetricName.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>MetricName (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>MetricName (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="MetricName (clients 0.9.0.0 API)";
+ parent.document.title="MetricName (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/Node.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/Node.html b/090/javadoc/org/apache/kafka/common/Node.html
index def15f9..b3b3631 100644
--- a/090/javadoc/org/apache/kafka/common/Node.html
+++ b/090/javadoc/org/apache/kafka/common/Node.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>Node (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>Node (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="Node (clients 0.9.0.0 API)";
+ parent.document.title="Node (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/PartitionInfo.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/PartitionInfo.html b/090/javadoc/org/apache/kafka/common/PartitionInfo.html
index 5af6dd0..78e45f8 100644
--- a/090/javadoc/org/apache/kafka/common/PartitionInfo.html
+++ b/090/javadoc/org/apache/kafka/common/PartitionInfo.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>PartitionInfo (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>PartitionInfo (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="PartitionInfo (clients 0.9.0.0 API)";
+ parent.document.title="PartitionInfo (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/TopicPartition.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/TopicPartition.html b/090/javadoc/org/apache/kafka/common/TopicPartition.html
index 9165439..fde8002 100644
--- a/090/javadoc/org/apache/kafka/common/TopicPartition.html
+++ b/090/javadoc/org/apache/kafka/common/TopicPartition.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>TopicPartition (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>TopicPartition (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TopicPartition (clients 0.9.0.0 API)";
+ parent.document.title="TopicPartition (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -93,11 +93,17 @@
<div class="description">
<ul class="blockList">
<li class="blockList">
+<dl>
+<dt>All Implemented Interfaces:</dt>
+<dd>java.io.Serializable</dd>
+</dl>
<hr>
<br>
<pre>public final class <span class="strong">TopicPartition</span>
-extends java.lang.Object</pre>
+extends java.lang.Object
+implements java.io.Serializable</pre>
<div class="block">A topic name and partition number</div>
+<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../serialized-form.html#org.apache.kafka.common.TopicPartition">Serialized Form</a></dd></dl>
</li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/ApiException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/ApiException.html b/090/javadoc/org/apache/kafka/common/errors/ApiException.html
index d4ace34..23225b4 100644
--- a/090/javadoc/org/apache/kafka/common/errors/ApiException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/ApiException.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_80) on Tue Nov 17 18:38:10 PST 2015 -->
-<title>ApiException (clients 0.9.0.0 API)</title>
-<meta name="date" content="2015-11-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu Feb 11 18:46:39 CST 2016 -->
+<title>ApiException (clients 0.9.0.1 API)</title>
+<meta name="date" content="2016-02-11">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
</head>
<body>
<script type="text/javascript"><!--
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="ApiException (clients 0.9.0.0 API)";
+ parent.document.title="ApiException (clients 0.9.0.1 API)";
}
//-->
</script>