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:06 UTC
[1/3] kafka-site git commit: updating docs for 0.9.0.1 release
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 2fb26e0a7 -> 7f47d1901
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/security.html
----------------------------------------------------------------------
diff --git a/090/security.html b/090/security.html
index 3acbbac..f348798 100644
--- a/090/security.html
+++ b/090/security.html
@@ -34,7 +34,7 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
<ol>
<li><h4><a id="security_ssl_key" href="#security_ssl_key">Generate SSL key and certificate for each Kafka broker</a></h4>
- The first step of deploying HTTPS is to generate the key and the certificate for each machine in the cluster. You can use Java’s keytool utility to accomplish this task.
+ The first step of deploying HTTPS is to generate the key and the certificate for each machine in the cluster. You can use Java's keytool utility to accomplish this task.
We will generate the key into a temporary keystore initially so that we can export and sign it later with CA.
<pre>
keytool -keystore server.keystore.jks -alias localhost -validity {validity} -genkey</pre>
@@ -54,7 +54,7 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
The generated CA is simply a public-private key pair and certificate, and it is intended to sign other certificates.<br>
- The next step is to add the generated CA to the **clients’ truststore** so that the clients can trust this CA:
+ The next step is to add the generated CA to the **clients' truststore** so that the clients can trust this CA:
<pre>
keytool -keystore server.truststore.jks -alias CARoot <b>-import</b> -file ca-cert</pre>
@@ -62,7 +62,7 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
<pre>
keytool -keystore client.truststore.jks -alias CARoot -import -file ca-cert</pre>
- In contrast to the keystore in step 1 that stores each machine’s own identity, the truststore of a client stores all the certificates that the client should trust. Importing a certificate into one’s truststore also means trusting all certificates that are signed by that certificate. As the analogy above, trusting the government (CA) also means trusting all passports (certificates) that it has issued. This attribute is called the chain of trust, and it is particularly useful when deploying SSL on a large Kafka cluster. You can sign all certificates in the cluster with a single CA, and have all machines share the same truststore that trusts the CA. That way all machines can authenticate all other machines.</li>
+ In contrast to the keystore in step 1 that stores each machine's own identity, the truststore of a client stores all the certificates that the client should trust. Importing a certificate into one's truststore also means trusting all certificates that are signed by that certificate. As the analogy above, trusting the government (CA) also means trusting all passports (certificates) that it has issued. This attribute is called the chain of trust, and it is particularly useful when deploying SSL on a large Kafka cluster. You can sign all certificates in the cluster with a single CA, and have all machines share the same truststore that trusts the CA. That way all machines can authenticate all other machines.</li>
<li><h4><a id="security_ssl_signing" href="#security_ssl_signing">Signing the certificate</a></h4>
The next step is to sign all certificates generated by step 1 with the CA generated in step 2. First, you need to export the certificate from the keystore:
@@ -206,7 +206,7 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
principal="kafka/kafka1.hostname.com@EXAMPLE.COM";
};
- # Zookeeper client authentication
+ // Zookeeper client authentication
Client {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
@@ -216,8 +216,9 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
};</pre>
</li>
- <li>Pass the name of the JAAS file as a JVM parameter to each Kafka broker:
+ <li>Pass the JAAS and optionally the krb5 file locations as JVM parameters to each Kafka broker (see <a href="https://docs.oracle.com/javase/8/docs/technotes/guides/security/jgss/tutorials/KerberosReq.html">here</a> for more details):
<pre>
+ -Djava.security.krb5.conf=/etc/kafka/krb5.conf
-Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf</pre>
</li>
<li>Make sure the keytabs configured in the JAAS file are readable by the operating system user who is starting kafka broker.</li>
@@ -263,8 +264,9 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
useTicketCache=true;
};</pre>
</li>
- <li>Pass the name of the JAAS file as a JVM parameter to the client JVM:
- <pre>
+ <li>Pass the JAAS and optionally krb5 file locations as JVM parameters to each client JVM (see <a href="https://docs.oracle.com/javase/8/docs/technotes/guides/security/jgss/tutorials/KerberosReq.html">here</a> for more details):
+ <pre>
+ -Djava.security.krb5.conf=/etc/kafka/krb5.conf
-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf</pre></li>
<li>Make sure the keytabs configured in the kafka_client_jaas.conf are readable by the operating system user who is starting kafka client.</li>
<li>Configure the following properties in producer.properties or consumer.properties:
@@ -273,6 +275,75 @@ Apache Kafka allows clients to connect over SSL. By default SSL is disabled but
sasl.kerberos.service.name=kafka</pre>
</li>
</ol></li>
+
+ <li><h4><a id="security_rolling_upgrade" href="#security_rolling_upgrade">Incorporating Security Features in a Running Cluster</a></h4>
+ You can secure a running cluster via one or more of the supported protocols discussed previously. This is done in phases:
+ <p></p>
+ <ul>
+ <li>Incrementally bounce the cluster nodes to open additional secured port(s).</li>
+ <li>Restart clients using the secured rather than PLAINTEXT port (assuming you are securing the client-broker connection).</li>
+ <li>Incrementally bounce the cluster again to enable broker-to-broker security (if this is required)</li>
+ <li>A final incremental bounce to close the PLAINTEXT port.</li>
+ </ul>
+ <p></p>
+ The specific steps for configuring SSL and SASL are described in sections <a href="#security_ssl">7.2</a> and <a href="#security_sasl">7.3</a>.
+ Follow these steps to enable security for your desired protocol(s).
+ <p></p>
+ The security implementation lets you configure different protocols for both broker-client and broker-broker communication.
+ These must be enabled in separate bounces. A PLAINTEXT port must be left open throughout so brokers and/or clients can continue to communicate.
+ <p></p>
+
+ When performing an incremental bounce stop the brokers cleanly via a SIGTERM. It's also good practice to wait for restarted replicas to return to the ISR list before moving onto the next node.
+ <p></p>
+ As an example, say we wish to encrypt both broker-client and broker-broker communication with SSL. In the first incremental bounce, a SSL port is opened on each node:
+ <pre>
+ listeners=PLAINTEXT://broker1:9091,SSL://broker1:9092</pre>
+
+ We then restart the clients, changing their config to point at the newly opened, secured port:
+
+ <pre>
+ bootstrap.servers = [broker1:9092,...]
+ security.protocol = SSL
+ ...etc</pre>
+
+ In the second incremental server bounce we instruct Kafka to use SSL as the broker-broker protocol (which will use the same SSL port):
+
+ <pre>
+ listeners=PLAINTEXT://broker1:9091,SSL://broker1:9092
+ security.inter.broker.protocol=SSL</pre>
+
+ In the final bounce we secure the cluster by closing the PLAINTEXT port:
+
+ <pre>
+ listeners=SSL://broker1:9092
+ security.inter.broker.protocol=SSL</pre>
+
+ Alternatively we might choose to open multiple ports so that different protocols can be used for broker-broker and broker-client communication. Say we wished to use SSL encryption throughout (i.e. for broker-broker and broker-client communication) but we'd like to add SASL authentication to the broker-client connection also. We would achieve this by opening two additional ports during the first bounce:
+
+ <pre>
+ listeners=PLAINTEXT://broker1:9091,SSL://broker1:9092,SASL_SSL://broker1:9093</pre>
+
+ We would then restart the clients, changing their config to point at the newly opened, SASL & SSL secured port:
+
+ <pre>
+ bootstrap.servers = [broker1:9093,...]
+ security.protocol = SASL_SSL
+ ...etc</pre>
+
+ The second server bounce would switch the cluster to use encrypted broker-broker communication via the SSL port we previously opened on port 9092:
+
+ <pre>
+ listeners=PLAINTEXT://broker1:9091,SSL://broker1:9092,SASL_SSL://broker1:9093
+ security.inter.broker.protocol=SSL</pre>
+
+ The final bounce secures the cluster by closing the PLAINTEXT port.
+
+ <pre>
+ listeners=SSL://broker1:9092,SASL_SSL://broker1:9093
+ security.inter.broker.protocol=SSL</pre>
+
+ ZooKeeper can be secured independently of the Kafka cluster. The steps for doing this are covered in section <a href="#zk_authz_migration">7.5.2</a>.
+ </li>
</ol>
<h3><a id="security_authz" href="#security_authz">7.4 Authorization and ACLs</a></h3>
@@ -283,6 +354,9 @@ One can also add super users in broker.properties like the following (note that
By default, the SSL user name will be of the form "CN=writeuser,OU=Unknown,O=Unknown,L=Unknown,ST=Unknown,C=Unknown". One can change that by setting a customized PrincipalBuilder in broker.properties like the following.
<pre>principal.builder.class=CustomizedPrincipalBuilderClass</pre>
By default, the SASL user name will be the primary part of the Kerberos principal. One can change that by setting <code>sasl.kerberos.principal.to.local.rules</code> to a customized rule in broker.properties.
+The format of <code>sasl.kerberos.principal.to.local.rules</code> is a list where each rule works in the same way as the auth_to_local in <a href="http://web.mit.edu/Kerberos/krb5-latest/doc/admin/conf_files/krb5_conf.html">Kerberos configuration file (krb5.conf)</a>. Each rules starts with RULE: and contains an expression in the format [n:string](regexp)s/pattern/replacement/g. See the kerberos documentation for more details. An example of adding a rule to properly translate user@MYDOMAIN.COM to user while also keeping the default rule in place is:
+<pre>sasl.kerberos.principal.to.local.rules=RULE:[1:$1@$0](.*@MYDOMAIN.COM)s/@.*//,DEFAULT</pre>
+
<h4><a id="security_authz_cli" href="#security_authz_cli">Command Line Interface</a></h4>
Kafka Authorization management CLI can be found under bin directory with all the other CLIs. The CLI script is called <b>kafka-acls.sh</b>. Following lists all the options that the script supports:
<p></p>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/upgrade.html
----------------------------------------------------------------------
diff --git a/090/upgrade.html b/090/upgrade.html
index 98ac570..19d9942 100644
--- a/090/upgrade.html
+++ b/090/upgrade.html
@@ -19,7 +19,10 @@
<h4><a id="upgrade_9" href="#upgrade_9">Upgrading from 0.8.0, 0.8.1.X or 0.8.2.X to 0.9.0.0</a></h4>
-0.9.0.0 has <a href="#upgrade_9_breaking">potential breaking changes</a> (please review before upgrading) and an inter-broker protocol change from previous versions. For a rolling upgrade:
+0.9.0.0 has <a href="#upgrade_9_breaking">potential breaking changes</a> (please review before upgrading) and an inter-broker protocol change from previous versions. This means that upgraded brokers and clients may not be compatible with older versions. It is important that you upgrade your Kafka cluster before upgrading your clients. If you are using MirrorMaker downstream clusters should be upgraded first as well.
+
+<p><b>For a rolling upgrade:</b></p>
+
<ol>
<li> Update server.properties file on all brokers and add the following property: inter.broker.protocol.version=0.8.2.X </li>
<li> Upgrade the brokers. This can be done a broker at a time by simply bringing it down, updating the code, and restarting it. </li>
@@ -39,7 +42,7 @@
<li> Broker IDs above 1000 are now reserved by default to automatically assigned broker IDs. If your cluster has existing broker IDs above that threshold make sure to increase the reserved.broker.max.id broker configuration property accordingly. </li>
<li> Configuration parameter replica.lag.max.messages was removed. Partition leaders will no longer consider the number of lagging messages when deciding which replicas are in sync. </li>
<li> Configuration parameter replica.lag.time.max.ms now refers not just to the time passed since last fetch request from replica, but also to time since the replica last caught up. Replicas that are still fetching messages from leaders but did not catch up to the latest messages in replica.lag.time.max.ms will be considered out of sync. </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> Compacted topics no longer accept messages without key and an exception is thrown by the producer if this is attempted. In 0.8.x, a message without key would cause the log compaction thread to subsequently complain and quit (and stop compacting all compacted topics). </li>
<li> MirrorMaker no longer supports multiple target clusters. As a result it will only accept a single --consumer.config parameter. To mirror multiple source clusters, you will need at least one MirrorMaker instance per source cluster, each with its own consumer configuration. </li>
<li> Tools packaged under <em>org.apache.kafka.clients.tools.*</em> have been moved to <em>org.apache.kafka.tools.*</em>. All included scripts will still function as usual, only custom code directly importing these classes will be affected. </li>
<li> The default Kafka JVM performance options (KAFKA_JVM_PERFORMANCE_OPTS) have been changed in kafka-run-class.sh. </li>
@@ -49,6 +52,14 @@
<li> By default all command line tools will print all logging messages to stderr instead of stout. </li>
</ul>
+<h5><a id="upgrade_901_notable" href="#upgrade_901_notable">Notable changes in 0.9.0.1</a></h5>
+
+<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> 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>
<ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/downloads.html
----------------------------------------------------------------------
diff --git a/downloads.html b/downloads.html
index 656e738..3c303cd 100644
--- a/downloads.html
+++ b/downloads.html
@@ -1,10 +1,29 @@
<!--#include virtual="includes/header.html" -->
<h1>Releases</h1>
-0.9.0.0 is the latest release. The current stable version is 0.8.2.2.
+0.9.0.1 is the latest release. The current stable version is 0.9.0.1.
<p>
You can verify your download by following these <a href="http://www.apache.org/info/verification.html">procedures</a> and using these <a href="http://kafka.apache.org/KEYS">KEYS</a>.
+<h3>0.9.0.1</h3>
+<ul>
+ <li>
+ <a href="https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.1/RELEASE_NOTES.html">Release Notes</a>
+ </li>
+ <li>
+ Source download: <a href="https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.1/kafka-0.9.0.1-src.tgz">kafka-0.9.0.1-src.tgz</a> (<a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka-0.9.0.1-src.tgz.asc">asc</a>, <a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka-0.9.0.1-src.tgz.md5">md5</a>)
+ </li>
+ <li>
+ Binary downloads:
+ <ul>
+ <li>Scala 2.10 - <a href="https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.1/kafka_2.10-0.9.0.1.tgz">kafka_2.10-0.9.0.1.tgz</a> (<a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka_2.10-0.9.0.1.tgz.asc">asc</a>, <a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka_2.10-0.9.0.1.tgz.md5">md5</a>)
+ </li>
+ <li>Scala 2.11 - <a href="https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz">kafka_2.11-0.9.0.1.tgz</a> (<a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz.asc">asc</a>, <a href="https://dist.apache.org/repos/dist/release/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz.md5">md5</a>)
+ </li>
+ </ul>
+We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.11 is recommended).
+ </li>
+</ul>
<h3>0.9.0.0</h3>
<ul>
<li>
[2/3] kafka-site git commit: updating docs for 0.9.0.1 release
Posted by ju...@apache.org.
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html b/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html
index 6a89cf0..29173a3 100644
--- a/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/AuthorizationException.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>AuthorizationException (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>AuthorizationException (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="AuthorizationException (clients 0.9.0.0 API)";
+ parent.document.title="AuthorizationException (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/errors/BrokerNotAvailableException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html b/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html
index 220d260..a74fe71 100644
--- a/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/BrokerNotAvailableException.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>BrokerNotAvailableException (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>BrokerNotAvailableException (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="BrokerNotAvailableException (clients 0.9.0.0 API)";
+ parent.document.title="BrokerNotAvailableException (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/errors/ControllerMovedException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html b/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html
index e07526e..8138436 100644
--- a/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/ControllerMovedException.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>ControllerMovedException (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>ControllerMovedException (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="ControllerMovedException (clients 0.9.0.0 API)";
+ parent.document.title="ControllerMovedException (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/errors/CorruptRecordException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html b/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html
index dd13ad7..4f2e17c 100644
--- a/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/CorruptRecordException.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>CorruptRecordException (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>CorruptRecordException (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="CorruptRecordException (clients 0.9.0.0 API)";
+ parent.document.title="CorruptRecordException (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/errors/DisconnectException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html b/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html
index 32d11a6..0b0b95e 100644
--- a/090/javadoc/org/apache/kafka/common/errors/DisconnectException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/DisconnectException.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>DisconnectException (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>DisconnectException (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="DisconnectException (clients 0.9.0.0 API)";
+ parent.document.title="DisconnectException (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -61,13 +61,13 @@
<ul class="subNavList">
<li>Summary: </li>
<li>Nested | </li>
-<li>Field | </li>
+<li><a href="#field_summary">Field</a> | </li>
<li><a href="#constructor_summary">Constr</a> | </li>
<li><a href="#methods_inherited_from_class_org.apache.kafka.common.errors.ApiException">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail: </li>
-<li>Field | </li>
+<li><a href="#field_detail">Field</a> | </li>
<li><a href="#constructor_detail">Constr</a> | </li>
<li>Method</li>
</ul>
@@ -139,6 +139,25 @@ extends <a href="../../../../../org/apache/kafka/common/errors/RetriableExceptio
<div class="summary">
<ul class="blockList">
<li class="blockList">
+<!-- =========== FIELD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field_summary">
+<!-- -->
+</a>
+<h3>Field Summary</h3>
+<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation">
+<caption><span>Fields</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Field and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>static <a href="../../../../../org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></code></td>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/common/errors/DisconnectException.html#INSTANCE">INSTANCE</a></strong></code> </td>
+</tr>
+</table>
+</li>
+</ul>
<!-- ======== CONSTRUCTOR SUMMARY ======== -->
<ul class="blockList">
<li class="blockList"><a name="constructor_summary">
@@ -201,6 +220,23 @@ extends <a href="../../../../../org/apache/kafka/common/errors/RetriableExceptio
<div class="details">
<ul class="blockList">
<li class="blockList">
+<!-- ============ FIELD DETAIL =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="field_detail">
+<!-- -->
+</a>
+<h3>Field Detail</h3>
+<a name="INSTANCE">
+<!-- -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>INSTANCE</h4>
+<pre>public static final <a href="../../../../../org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a> INSTANCE</pre>
+</li>
+</ul>
+</li>
+</ul>
<!-- ========= CONSTRUCTOR DETAIL ======== -->
<ul class="blockList">
<li class="blockList"><a name="constructor_detail">
@@ -295,13 +331,13 @@ extends <a href="../../../../../org/apache/kafka/common/errors/RetriableExceptio
<ul class="subNavList">
<li>Summary: </li>
<li>Nested | </li>
-<li>Field | </li>
+<li><a href="#field_summary">Field</a> | </li>
<li><a href="#constructor_summary">Constr</a> | </li>
<li><a href="#methods_inherited_from_class_org.apache.kafka.common.errors.ApiException">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail: </li>
-<li>Field | </li>
+<li><a href="#field_detail">Field</a> | </li>
<li><a href="#constructor_detail">Constr</a> | </li>
<li>Method</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/errors/GroupAuthorizationException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/GroupAuthorizationException.html b/090/javadoc/org/apache/kafka/common/errors/GroupAuthorizationException.html
index 6c5b312..793471f 100644
--- a/090/javadoc/org/apache/kafka/common/errors/GroupAuthorizationException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/GroupAuthorizationException.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>GroupAuthorizationException (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>GroupAuthorizationException (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="GroupAuthorizationException (clients 0.9.0.0 API)";
+ parent.document.title="GroupAuthorizationException (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/errors/GroupCoordinatorNotAvailableException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html b/090/javadoc/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html
index ddfc782..6490df8 100644
--- a/090/javadoc/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.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>GroupCoordinatorNotAvailableException (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>GroupCoordinatorNotAvailableException (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="GroupCoordinatorNotAvailableException (clients 0.9.0.0 API)";
+ parent.document.title="GroupCoordinatorNotAvailableException (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/errors/GroupLoadInProgressException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/GroupLoadInProgressException.html b/090/javadoc/org/apache/kafka/common/errors/GroupLoadInProgressException.html
index 4108df1..01e5dff 100644
--- a/090/javadoc/org/apache/kafka/common/errors/GroupLoadInProgressException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/GroupLoadInProgressException.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>GroupLoadInProgressException (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>GroupLoadInProgressException (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="GroupLoadInProgressException (clients 0.9.0.0 API)";
+ parent.document.title="GroupLoadInProgressException (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/errors/IllegalGenerationException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/IllegalGenerationException.html b/090/javadoc/org/apache/kafka/common/errors/IllegalGenerationException.html
index 750a4eb..4e5c302 100644
--- a/090/javadoc/org/apache/kafka/common/errors/IllegalGenerationException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/IllegalGenerationException.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>IllegalGenerationException (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>IllegalGenerationException (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="IllegalGenerationException (clients 0.9.0.0 API)";
+ parent.document.title="IllegalGenerationException (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/errors/InterruptException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/InterruptException.html b/090/javadoc/org/apache/kafka/common/errors/InterruptException.html
index 52e014c..55aca13 100644
--- a/090/javadoc/org/apache/kafka/common/errors/InterruptException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/InterruptException.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>InterruptException (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>InterruptException (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="InterruptException (clients 0.9.0.0 API)";
+ parent.document.title="InterruptException (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/errors/InvalidMetadataException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/InvalidMetadataException.html b/090/javadoc/org/apache/kafka/common/errors/InvalidMetadataException.html
index e1e645f..628ba0e 100644
--- a/090/javadoc/org/apache/kafka/common/errors/InvalidMetadataException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/InvalidMetadataException.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>InvalidMetadataException (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>InvalidMetadataException (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="InvalidMetadataException (clients 0.9.0.0 API)";
+ parent.document.title="InvalidMetadataException (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/errors/InvalidRequiredAcksException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.html b/090/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.html
index e1f312c..1b5f18a 100644
--- a/090/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/InvalidRequiredAcksException.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>InvalidRequiredAcksException (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>InvalidRequiredAcksException (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="InvalidRequiredAcksException (clients 0.9.0.0 API)";
+ parent.document.title="InvalidRequiredAcksException (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/errors/InvalidTopicException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/InvalidTopicException.html b/090/javadoc/org/apache/kafka/common/errors/InvalidTopicException.html
index 6588310..b97fb98 100644
--- a/090/javadoc/org/apache/kafka/common/errors/InvalidTopicException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/InvalidTopicException.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>InvalidTopicException (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>InvalidTopicException (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="InvalidTopicException (clients 0.9.0.0 API)";
+ parent.document.title="InvalidTopicException (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/errors/LeaderNotAvailableException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/LeaderNotAvailableException.html b/090/javadoc/org/apache/kafka/common/errors/LeaderNotAvailableException.html
index 97b1ac7..c5ad26f 100644
--- a/090/javadoc/org/apache/kafka/common/errors/LeaderNotAvailableException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/LeaderNotAvailableException.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>LeaderNotAvailableException (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>LeaderNotAvailableException (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="LeaderNotAvailableException (clients 0.9.0.0 API)";
+ parent.document.title="LeaderNotAvailableException (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/errors/NetworkException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/NetworkException.html b/090/javadoc/org/apache/kafka/common/errors/NetworkException.html
index 3185cac..40f61b7 100644
--- a/090/javadoc/org/apache/kafka/common/errors/NetworkException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/NetworkException.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>NetworkException (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>NetworkException (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="NetworkException (clients 0.9.0.0 API)";
+ parent.document.title="NetworkException (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/errors/NotCoordinatorForGroupException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/NotCoordinatorForGroupException.html b/090/javadoc/org/apache/kafka/common/errors/NotCoordinatorForGroupException.html
index 5940ccd..f227056 100644
--- a/090/javadoc/org/apache/kafka/common/errors/NotCoordinatorForGroupException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/NotCoordinatorForGroupException.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>NotCoordinatorForGroupException (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>NotCoordinatorForGroupException (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="NotCoordinatorForGroupException (clients 0.9.0.0 API)";
+ parent.document.title="NotCoordinatorForGroupException (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/errors/NotEnoughReplicasAfterAppendException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html b/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html
index d407621..fd46fa9 100644
--- a/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.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>NotEnoughReplicasAfterAppendException (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>NotEnoughReplicasAfterAppendException (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="NotEnoughReplicasAfterAppendException (clients 0.9.0.0 API)";
+ parent.document.title="NotEnoughReplicasAfterAppendException (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/errors/NotEnoughReplicasException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasException.html b/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasException.html
index 9e9e121..75849bf 100644
--- a/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/NotEnoughReplicasException.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>NotEnoughReplicasException (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>NotEnoughReplicasException (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="NotEnoughReplicasException (clients 0.9.0.0 API)";
+ parent.document.title="NotEnoughReplicasException (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/errors/NotLeaderForPartitionException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/NotLeaderForPartitionException.html b/090/javadoc/org/apache/kafka/common/errors/NotLeaderForPartitionException.html
index 70576e8..e5a5afc 100644
--- a/090/javadoc/org/apache/kafka/common/errors/NotLeaderForPartitionException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/NotLeaderForPartitionException.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>NotLeaderForPartitionException (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>NotLeaderForPartitionException (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="NotLeaderForPartitionException (clients 0.9.0.0 API)";
+ parent.document.title="NotLeaderForPartitionException (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/errors/OffsetMetadataTooLarge.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/OffsetMetadataTooLarge.html b/090/javadoc/org/apache/kafka/common/errors/OffsetMetadataTooLarge.html
index bf2432d..ca14625 100644
--- a/090/javadoc/org/apache/kafka/common/errors/OffsetMetadataTooLarge.html
+++ b/090/javadoc/org/apache/kafka/common/errors/OffsetMetadataTooLarge.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>OffsetMetadataTooLarge (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>OffsetMetadataTooLarge (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="OffsetMetadataTooLarge (clients 0.9.0.0 API)";
+ parent.document.title="OffsetMetadataTooLarge (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/errors/RebalanceInProgressException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/RebalanceInProgressException.html b/090/javadoc/org/apache/kafka/common/errors/RebalanceInProgressException.html
index 2f052ba..536f94d 100644
--- a/090/javadoc/org/apache/kafka/common/errors/RebalanceInProgressException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/RebalanceInProgressException.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>RebalanceInProgressException (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>RebalanceInProgressException (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="RebalanceInProgressException (clients 0.9.0.0 API)";
+ parent.document.title="RebalanceInProgressException (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/errors/RecordBatchTooLargeException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/RecordBatchTooLargeException.html b/090/javadoc/org/apache/kafka/common/errors/RecordBatchTooLargeException.html
index 34e603c..5b80ba4 100644
--- a/090/javadoc/org/apache/kafka/common/errors/RecordBatchTooLargeException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/RecordBatchTooLargeException.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>RecordBatchTooLargeException (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>RecordBatchTooLargeException (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="RecordBatchTooLargeException (clients 0.9.0.0 API)";
+ parent.document.title="RecordBatchTooLargeException (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/errors/RecordTooLargeException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html b/090/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html
index cfabaf5..1f4b435 100644
--- a/090/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/RecordTooLargeException.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>RecordTooLargeException (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>RecordTooLargeException (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="RecordTooLargeException (clients 0.9.0.0 API)";
+ parent.document.title="RecordTooLargeException (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/errors/RetriableException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/RetriableException.html b/090/javadoc/org/apache/kafka/common/errors/RetriableException.html
index f3530d1..fc536a3 100644
--- a/090/javadoc/org/apache/kafka/common/errors/RetriableException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/RetriableException.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>RetriableException (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>RetriableException (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="RetriableException (clients 0.9.0.0 API)";
+ parent.document.title="RetriableException (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/errors/SerializationException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/SerializationException.html b/090/javadoc/org/apache/kafka/common/errors/SerializationException.html
index 6b96054..d31243d 100644
--- a/090/javadoc/org/apache/kafka/common/errors/SerializationException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/SerializationException.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>SerializationException (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>SerializationException (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="SerializationException (clients 0.9.0.0 API)";
+ parent.document.title="SerializationException (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/errors/TimeoutException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/TimeoutException.html b/090/javadoc/org/apache/kafka/common/errors/TimeoutException.html
index aea7964..399c4f3 100644
--- a/090/javadoc/org/apache/kafka/common/errors/TimeoutException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/TimeoutException.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>TimeoutException (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>TimeoutException (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="TimeoutException (clients 0.9.0.0 API)";
+ parent.document.title="TimeoutException (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/errors/TopicAuthorizationException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/TopicAuthorizationException.html b/090/javadoc/org/apache/kafka/common/errors/TopicAuthorizationException.html
index e71c3fb..69618a5 100644
--- a/090/javadoc/org/apache/kafka/common/errors/TopicAuthorizationException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/TopicAuthorizationException.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>TopicAuthorizationException (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>TopicAuthorizationException (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="TopicAuthorizationException (clients 0.9.0.0 API)";
+ parent.document.title="TopicAuthorizationException (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/errors/UnknownMemberIdException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.html b/090/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.html
index 37257dd..8a62781 100644
--- a/090/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/UnknownMemberIdException.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>UnknownMemberIdException (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>UnknownMemberIdException (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="UnknownMemberIdException (clients 0.9.0.0 API)";
+ parent.document.title="UnknownMemberIdException (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/errors/UnknownServerException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/UnknownServerException.html b/090/javadoc/org/apache/kafka/common/errors/UnknownServerException.html
index 9362236..e0c1d95 100644
--- a/090/javadoc/org/apache/kafka/common/errors/UnknownServerException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/UnknownServerException.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>UnknownServerException (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>UnknownServerException (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="UnknownServerException (clients 0.9.0.0 API)";
+ parent.document.title="UnknownServerException (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/errors/UnknownTopicOrPartitionException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html b/090/javadoc/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html
index 0ee38ae..f8e24a9 100644
--- a/090/javadoc/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/UnknownTopicOrPartitionException.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>UnknownTopicOrPartitionException (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>UnknownTopicOrPartitionException (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="UnknownTopicOrPartitionException (clients 0.9.0.0 API)";
+ parent.document.title="UnknownTopicOrPartitionException (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/errors/WakeupException.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/WakeupException.html b/090/javadoc/org/apache/kafka/common/errors/WakeupException.html
index 1f29f49..c7f8a19 100644
--- a/090/javadoc/org/apache/kafka/common/errors/WakeupException.html
+++ b/090/javadoc/org/apache/kafka/common/errors/WakeupException.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>WakeupException (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>WakeupException (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="WakeupException (clients 0.9.0.0 API)";
+ parent.document.title="WakeupException (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/errors/package-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/package-frame.html b/090/javadoc/org/apache/kafka/common/errors/package-frame.html
index 56c906d..91e3d0f 100644
--- a/090/javadoc/org/apache/kafka/common/errors/package-frame.html
+++ b/090/javadoc/org/apache/kafka/common/errors/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.common.errors (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.common.errors (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/common/errors/package-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/package-summary.html b/090/javadoc/org/apache/kafka/common/errors/package-summary.html
index 333015b..63dda23 100644
--- a/090/javadoc/org/apache/kafka/common/errors/package-summary.html
+++ b/090/javadoc/org/apache/kafka/common/errors/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.common.errors (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.common.errors (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.common.errors (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common.errors (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/errors/package-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/errors/package-tree.html b/090/javadoc/org/apache/kafka/common/errors/package-tree.html
index 48a4772..5cea9b3 100644
--- a/090/javadoc/org/apache/kafka/common/errors/package-tree.html
+++ b/090/javadoc/org/apache/kafka/common/errors/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.common.errors 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.common.errors 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.common.errors Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common.errors 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/package-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/package-frame.html b/090/javadoc/org/apache/kafka/common/package-frame.html
index ae20127..a2d2bb2 100644
--- a/090/javadoc/org/apache/kafka/common/package-frame.html
+++ b/090/javadoc/org/apache/kafka/common/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.common (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.common (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/common/package-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/package-summary.html b/090/javadoc/org/apache/kafka/common/package-summary.html
index e4d6d9f..ae3be9c 100644
--- a/090/javadoc/org/apache/kafka/common/package-summary.html
+++ b/090/javadoc/org/apache/kafka/common/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.common (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.common (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.common (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common (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/package-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/package-tree.html b/090/javadoc/org/apache/kafka/common/package-tree.html
index 45a5155..be781b6 100644
--- a/090/javadoc/org/apache/kafka/common/package-tree.html
+++ b/090/javadoc/org/apache/kafka/common/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.common 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.common 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.common Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common Class Hierarchy (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -90,7 +90,7 @@
</li>
</ul>
</li>
-<li type="circle">org.apache.kafka.common.<a href="../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common"><span class="strong">TopicPartition</span></a></li>
+<li type="circle">org.apache.kafka.common.<a href="../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common"><span class="strong">TopicPartition</span></a> (implements java.io.Serializable)</li>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html
index faa5ea3..82f7f2a 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.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>ByteArrayDeserializer (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>ByteArrayDeserializer (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="ByteArrayDeserializer (clients 0.9.0.0 API)";
+ parent.document.title="ByteArrayDeserializer (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/serialization/ByteArraySerializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html b/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html
index 71681fa..4301d46 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.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>ByteArraySerializer (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>ByteArraySerializer (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="ByteArraySerializer (clients 0.9.0.0 API)";
+ parent.document.title="ByteArraySerializer (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/serialization/Deserializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html b/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html
index e3358ac..2d1a71c 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/Deserializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/Deserializer.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>Deserializer (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>Deserializer (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="Deserializer (clients 0.9.0.0 API)";
+ parent.document.title="Deserializer (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/serialization/IntegerDeserializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html
index d6768cb..5a8c0bc 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/IntegerDeserializer.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>IntegerDeserializer (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>IntegerDeserializer (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="IntegerDeserializer (clients 0.9.0.0 API)";
+ parent.document.title="IntegerDeserializer (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/serialization/IntegerSerializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html
index e1dd089..66983fe 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/IntegerSerializer.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>IntegerSerializer (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>IntegerSerializer (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="IntegerSerializer (clients 0.9.0.0 API)";
+ parent.document.title="IntegerSerializer (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/serialization/LongDeserializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html
index 0b58719..9cf8110 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/LongDeserializer.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>LongDeserializer (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>LongDeserializer (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="LongDeserializer (clients 0.9.0.0 API)";
+ parent.document.title="LongDeserializer (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/serialization/LongSerializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html
index 49d52e0..cc2db34 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/LongSerializer.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>LongSerializer (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>LongSerializer (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="LongSerializer (clients 0.9.0.0 API)";
+ parent.document.title="LongSerializer (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/serialization/Serializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/Serializer.html b/090/javadoc/org/apache/kafka/common/serialization/Serializer.html
index 69ca220..f65cfde 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/Serializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/Serializer.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>Serializer (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>Serializer (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="Serializer (clients 0.9.0.0 API)";
+ parent.document.title="Serializer (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/serialization/StringDeserializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html b/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html
index fed4830..24c7780 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/StringDeserializer.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>StringDeserializer (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>StringDeserializer (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="StringDeserializer (clients 0.9.0.0 API)";
+ parent.document.title="StringDeserializer (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/serialization/StringSerializer.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html b/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html
index eaa4a04..a58c9be 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/StringSerializer.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>StringSerializer (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>StringSerializer (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="StringSerializer (clients 0.9.0.0 API)";
+ parent.document.title="StringSerializer (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/serialization/package-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-frame.html b/090/javadoc/org/apache/kafka/common/serialization/package-frame.html
index 5e66acc..b188beb 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/package-frame.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/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.common.serialization (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.common.serialization (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/common/serialization/package-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-summary.html b/090/javadoc/org/apache/kafka/common/serialization/package-summary.html
index 364ac89..d008d3f 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/package-summary.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/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.common.serialization (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.common.serialization (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.common.serialization (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common.serialization (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/serialization/package-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/org/apache/kafka/common/serialization/package-tree.html b/090/javadoc/org/apache/kafka/common/serialization/package-tree.html
index 5c005b6..d08f197 100644
--- a/090/javadoc/org/apache/kafka/common/serialization/package-tree.html
+++ b/090/javadoc/org/apache/kafka/common/serialization/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.common.serialization 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.common.serialization 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.common.serialization Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="org.apache.kafka.common.serialization Class Hierarchy (clients 0.9.0.1 API)";
}
//-->
</script>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-frame.html
----------------------------------------------------------------------
diff --git a/090/javadoc/overview-frame.html b/090/javadoc/overview-frame.html
index 989bbbe..8b7e1c9 100644
--- a/090/javadoc/overview-frame.html
+++ b/090/javadoc/overview-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>Overview 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:39 CST 2016 -->
+<title>Overview 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>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-summary.html
----------------------------------------------------------------------
diff --git a/090/javadoc/overview-summary.html b/090/javadoc/overview-summary.html
index 5fcda96..2dd9557 100644
--- a/090/javadoc/overview-summary.html
+++ b/090/javadoc/overview-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>Overview (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>Overview (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="Overview (clients 0.9.0.0 API)";
+ parent.document.title="Overview (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -62,7 +62,7 @@
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<div class="header">
-<h1 class="title">clients 0.9.0.0 API</h1>
+<h1 class="title">clients 0.9.0.1 API</h1>
</div>
<div class="contentContainer">
<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Packages table, listing packages, and an explanation">
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/overview-tree.html
----------------------------------------------------------------------
diff --git a/090/javadoc/overview-tree.html b/090/javadoc/overview-tree.html
index 714c997..3d2242d 100644
--- a/090/javadoc/overview-tree.html
+++ b/090/javadoc/overview-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>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:40 CST 2016 -->
+<title>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="Class Hierarchy (clients 0.9.0.0 API)";
+ parent.document.title="Class Hierarchy (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -104,7 +104,7 @@
<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.producer.<a href="org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer"><span class="strong">MockProducer</span></a><K,V> (implements org.apache.kafka.clients.producer.<a href="org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><K,V>)</li>
<li type="circle">org.apache.kafka.common.<a href="org/apache/kafka/common/Node.html" title="class in org.apache.kafka.common"><span class="strong">Node</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></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">org.apache.kafka.common.<a href="org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common"><span class="strong">PartitionInfo</span></a></li>
<li type="circle">org.apache.kafka.clients.producer.<a href="org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer"><span class="strong">ProducerRecord</span></a><K,V></li>
<li type="circle">org.apache.kafka.clients.producer.<a href="org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer"><span class="strong">RecordMetadata</span></a></li>
@@ -178,7 +178,7 @@
</li>
</ul>
</li>
-<li type="circle">org.apache.kafka.common.<a href="org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common"><span class="strong">TopicPartition</span></a></li>
+<li type="circle">org.apache.kafka.common.<a href="org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common"><span class="strong">TopicPartition</span></a> (implements java.io.Serializable)</li>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/javadoc/serialized-form.html
----------------------------------------------------------------------
diff --git a/090/javadoc/serialized-form.html b/090/javadoc/serialized-form.html
index 1d4f8d3..7e4b725 100644
--- a/090/javadoc/serialized-form.html
+++ b/090/javadoc/serialized-form.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>Serialized Form (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>Serialized Form (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="Serialized Form (clients 0.9.0.0 API)";
+ parent.document.title="Serialized Form (clients 0.9.0.1 API)";
}
//-->
</script>
@@ -105,6 +105,28 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.kafka.clients.consumer.OffsetAndMetadata">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">org.apache.kafka.clients.consumer.OffsetAndMetadata</a> extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList"><a name="serializedForm">
+<!-- -->
+</a>
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockList">
+<h4>offset</h4>
+<pre>long offset</pre>
+</li>
+<li class="blockListLast">
+<h4>metadata</h4>
+<pre>java.lang.String metadata</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
<li class="blockList"><a name="org.apache.kafka.clients.consumer.OffsetOutOfRangeException">
<!-- -->
</a>
@@ -155,6 +177,32 @@
<dd>1L</dd>
</dl>
</li>
+<li class="blockList"><a name="org.apache.kafka.common.TopicPartition">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">org.apache.kafka.common.TopicPartition</a> extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList"><a name="serializedForm">
+<!-- -->
+</a>
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockList">
+<h4>hash</h4>
+<pre>int hash</pre>
+</li>
+<li class="blockList">
+<h4>partition</h4>
+<pre>int partition</pre>
+</li>
+<li class="blockListLast">
+<h4>topic</h4>
+<pre>java.lang.String topic</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
</ul>
</li>
<li class="blockList">
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/kafka_config.html
----------------------------------------------------------------------
diff --git a/090/kafka_config.html b/090/kafka_config.html
index f851160..efefeb9 100644
--- a/090/kafka_config.html
+++ b/090/kafka_config.html
@@ -144,6 +144,8 @@
<tr>
<td>zookeeper.set.acl</td><td>Set client to use secure ACLs</td><td>boolean</td><td>false</td><td></td><td>high</td></tr>
<tr>
+<td>broker.id.generation.enable</td><td>Enable automatic broker id generation on the server? When enabled the value configured for reserved.broker.max.id should be reviewed.</td><td>boolean</td><td>true</td><td></td><td>medium</td></tr>
+<tr>
<td>connections.max.idle.ms</td><td>Idle connections timeout: the server socket processor threads close the connections that idle more than this</td><td>long</td><td>600000</td><td></td><td>medium</td></tr>
<tr>
<td>controlled.shutdown.enable</td><td>Enable controlled shutdown of the server</td><td>boolean</td><td>true</td><td></td><td>medium</td></tr>
@@ -168,11 +170,11 @@
<tr>
<td>log.cleaner.backoff.ms</td><td>The amount of time to sleep when there are no logs to clean</td><td>long</td><td>15000</td><td>[0,...]</td><td>medium</td></tr>
<tr>
-<td>log.cleaner.dedupe.buffer.size</td><td>The total memory used for log deduplication across all cleaner threads</td><td>long</td><td>524288000</td><td></td><td>medium</td></tr>
+<td>log.cleaner.dedupe.buffer.size</td><td>The total memory used for log deduplication across all cleaner threads</td><td>long</td><td>134217728</td><td></td><td>medium</td></tr>
<tr>
<td>log.cleaner.delete.retention.ms</td><td>How long are delete records retained?</td><td>long</td><td>86400000</td><td></td><td>medium</td></tr>
<tr>
-<td>log.cleaner.enable</td><td>Should we enable log cleaning?</td><td>boolean</td><td>false</td><td></td><td>medium</td></tr>
+<td>log.cleaner.enable</td><td>Enable the log cleaner process to run on the server? Should be enabled if using any topics with a cleanup.policy=compact including the internal offsets topic. If disabled those topics will not be compacted and continually grow in size.</td><td>boolean</td><td>true</td><td></td><td>medium</td></tr>
<tr>
<td>log.cleaner.io.buffer.load.factor</td><td>Log cleaner dedupe buffer load factor. The percentage full the dedupe buffer can become. A higher value will allow more log to be cleaned at once but will lead to more hash collisions</td><td>double</td><td>0.9</td><td></td><td>medium</td></tr>
<tr>
@@ -212,7 +214,7 @@
<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>medium</td></tr>
<tr>
-<td>sasl.kerberos.principal.to.local.rules</td><td>A list of rules for mapping from principal names to short names (typically operating system usernames). The rules are evaluated in order and the first rule that matches a principal name is used to map it to a short name. Any later rules in the list are ignored. By default, principal names of the form {username}/{hostname}@{REALM} are mapped to {username}.</td><td>list</td><td>[DEFAULT]</td><td></td><td>medium</td></tr>
+<td>sasl.kerberos.principal.to.local.rules</td><td>A list of rules for mapping from principal names to short names (typically operating system usernames). The rules are evaluated in order and the first rule that matches a principal name is used to map it to a short name. Any later rules in the list are ignored. By default, principal names of the form {username}/{hostname}@{REALM} are mapped to {username}. For more details on the format please see <a href="#security_authz"> security authorization and acls</a>.</td><td>list</td><td>[DEFAULT]</td><td></td><td>medium</td></tr>
<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>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/ops.html
----------------------------------------------------------------------
diff --git a/090/ops.html b/090/ops.html
index 04d4e7a..e6356ba 100644
--- a/090/ops.html
+++ b/090/ops.html
@@ -62,7 +62,9 @@ And finally deleting a topic:
Topic deletion option is disabled by default. To enable it set the server config
<pre>delete.topic.enable=true</pre>
<p>
-Kafka does not currently support reducing the number of partitions for a topic or changing the replication factor.
+Kafka does not currently support reducing the number of partitions for a topic.
+<p>
+Instructions for changing the replication factor of a topic can be found <a href="#basic_ops_increase_replication_factor">here</a>.
<h4><a id="basic_ops_restarting" href="#basic_ops_restarting">Graceful shutdown</a></h4>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/7f47d190/090/quickstart.html
----------------------------------------------------------------------
diff --git a/090/quickstart.html b/090/quickstart.html
index 14f7518..c8933c3 100644
--- a/090/quickstart.html
+++ b/090/quickstart.html
@@ -200,7 +200,7 @@ Kafka Connect is a tool included with Kafka that imports and exports data to Kaf
how to run Kafka Connect with simple connectors that import data from a file to a Kafka topic and export data from a
Kafka topic to a file.
-First, we’ll start by creating some seed data to test with:
+First, we'll start by creating some seed data to test with:
<pre>
> <b>echo -e "foo\nbar" > test.txt</b>
[3/3] kafka-site git commit: updating docs for 0.9.0.1 release
Posted by ju...@apache.org.
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>