You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2017/11/17 14:47:08 UTC
[37/51] [partial] kafka-site git commit: Update site for 0.11.0.2
release
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html b/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html
index 056a1b0..d2a3fc9 100644
--- a/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html
+++ b/0110/javadoc/org/apache/kafka/clients/producer/MockProducer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 -->
-<title>MockProducer (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>MockProducer (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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 (kafka 0.11.0.1 API)";
+ parent.document.title="MockProducer (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -83,7 +83,7 @@
</div>
<div class="contentContainer">
<ul class="inheritance">
-<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li>
+<li>java.lang.Object</li>
<li>
<ul class="inheritance">
<li>org.apache.kafka.clients.producer.MockProducer<K,V></li>
@@ -95,12 +95,12 @@
<li class="blockList">
<dl>
<dt>All Implemented Interfaces:</dt>
-<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>, <a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><K,V></dd>
+<dd>java.io.Closeable, java.lang.AutoCloseable, <a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><K,V></dd>
</dl>
<hr>
<br>
<pre>public class <span class="strong">MockProducer<K,V></span>
-extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>
+extends java.lang.Object
implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><K,V></pre>
<div class="block">A mock of the producer interface you can use for testing code that uses Kafka.
<p>
@@ -194,7 +194,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#close(long,%20java.util.concurrent.TimeUnit)">close</a></strong>(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> timeUnit)</code>
+ java.util.concurrent.TimeUnit timeUnit)</code>
<div class="block">Tries to close the producer cleanly within the specified timeout.</div>
</td>
</tr>
@@ -219,14 +219,14 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>>>></code></td>
+<td class="colFirst"><code>java.util.List<java.util.Map<java.lang.String,java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>>>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#consumerGroupOffsetsHistory()">consumerGroupOffsetsHistory</a></strong>()</code>
<div class="block">Get the list of committed consumer group offsets since the last call to <a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#clear()"><code>clear()</code></a></div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>boolean</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#errorNext(java.lang.RuntimeException)">errorNext</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/RuntimeException.html?is-external=true" title="class or interface in java.lang">RuntimeException</a> e)</code>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#errorNext(java.lang.RuntimeException)">errorNext</a></strong>(java.lang.RuntimeException e)</code>
<div class="block">Complete the earliest uncompleted call with the given error.</div>
</td>
</tr>
@@ -245,7 +245,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#flushed()">flushed</a></strong>()</code> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>>></code></td>
+<td class="colFirst"><code>java.util.List<<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#history()">history</a></strong>()</code>
<div class="block">Get the list of sent records since the last call to <a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#clear()"><code>clear()</code></a></div>
</td>
@@ -257,25 +257,25 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,<a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
+<td class="colFirst"><code>java.util.Map<<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,<a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#metrics()">metrics</a></strong>()</code>
<div class="block">Return a map of metrics maintained by the producer</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>></code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic)</code>
+<td class="colFirst"><code>java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>></code></td>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(java.lang.String topic)</code>
<div class="block">Get a list of partitions for the given topic for custom partition assignment.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
+<td class="colFirst"><code>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord)">send</a></strong>(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record)</code>
<div class="block">Adds the record to the list of sent records.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
+<td class="colFirst"><code>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord,%20org.apache.kafka.clients.producer.Callback)">send</a></strong>(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record,
<a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</code>
<div class="block">Adds the record to the list of sent records.</div>
@@ -283,8 +283,8 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)">sendOffsetsToTransaction</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> consumerGroupId)</code>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)">sendOffsetsToTransaction</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
+ java.lang.String consumerGroupId)</code>
<div class="block">See <a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)"><code>KafkaProducer.sendOffsetsToTransaction(Map, String)</code></a></div>
</td>
</tr>
@@ -313,8 +313,8 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
<!-- -->
</a>
-<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3>
-<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang
/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li>
+<h3>Methods inherited from class java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
</ul>
</li>
</ul>
@@ -435,8 +435,8 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>sendOffsetsToTransaction</h4>
-<pre>public void sendOffsetsToTransaction(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> consumerGroupId)
+<pre>public void sendOffsetsToTransaction(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
+ java.lang.String consumerGroupId)
throws <a href="../../../../../org/apache/kafka/common/errors/ProducerFencedException.html" title="class in org.apache.kafka.common.errors">ProducerFencedException</a></pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)">Producer</a></code></strong></div>
<div class="block">See <a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)"><code>KafkaProducer.sendOffsetsToTransaction(Map, String)</code></a></div>
@@ -487,7 +487,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>send</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record)</pre>
+<pre>public java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record)</pre>
<div class="block">Adds the record to the list of sent records. The <a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer"><code>RecordMetadata</code></a> returned will be immediately satisfied.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -502,8 +502,8 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>send</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record,
- <a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</pre>
+<pre>public java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>> record,
+ <a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</pre>
<div class="block">Adds the record to the list of sent records.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -532,7 +532,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>partitionsFor</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic)</pre>
+<pre>public java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(java.lang.String topic)</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#partitionsFor(java.lang.String)">Producer</a></code></strong></div>
<div class="block">Get a list of partitions for the given topic for custom partition assignment. The partition metadata will change
over time so this list should not be cached.</div>
@@ -548,7 +548,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>metrics</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,<a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
+<pre>public java.util.Map<<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,<a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#metrics()">Producer</a></code></strong></div>
<div class="block">Return a map of metrics maintained by the producer</div>
<dl>
@@ -568,9 +568,9 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<div class="block">Close this producer</div>
<dl>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true#close()" title="class or interface in java.io">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></code></dd>
+<dd><code>close</code> in interface <code>java.io.Closeable</code></dd>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true#close()" title="class or interface in java.lang">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></code></dd>
+<dd><code>close</code> in interface <code>java.lang.AutoCloseable</code></dd>
<dt><strong>Specified by:</strong></dt>
<dd><code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#close()">close</a></code> in interface <code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer">Producer</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>></code></dd>
</dl>
@@ -583,7 +583,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<li class="blockList">
<h4>close</h4>
<pre>public void close(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> timeUnit)</pre>
+ java.util.concurrent.TimeUnit timeUnit)</pre>
<div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#close(long,%20java.util.concurrent.TimeUnit)">Producer</a></code></strong></div>
<div class="block">Tries to close the producer cleanly within the specified timeout. If the close does not complete within the
timeout, fail any pending send requests and force close the producer.</div>
@@ -680,7 +680,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>history</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>>> history()</pre>
+<pre>public java.util.List<<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="type parameter in MockProducer">V</a>>> history()</pre>
<div class="block">Get the list of sent records since the last call to <a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#clear()"><code>clear()</code></a></div>
</li>
</ul>
@@ -690,7 +690,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockList">
<li class="blockList">
<h4>consumerGroupOffsetsHistory</h4>
-<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>>>> consumerGroupOffsetsHistory()</pre>
+<pre>public java.util.List<java.util.Map<java.lang.String,java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>>>> consumerGroupOffsetsHistory()</pre>
<div class="block">Get the list of committed consumer group offsets since the last call to <a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html#clear()"><code>clear()</code></a></div>
</li>
</ul>
@@ -721,7 +721,7 @@ implements <a href="../../../../../org/apache/kafka/clients/producer/Producer.ht
<ul class="blockListLast">
<li class="blockList">
<h4>errorNext</h4>
-<pre>public boolean errorNext(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/RuntimeException.html?is-external=true" title="class or interface in java.lang">RuntimeException</a> e)</pre>
+<pre>public boolean errorNext(java.lang.RuntimeException e)</pre>
<div class="block">Complete the earliest uncompleted call with the given error.</div>
<dl><dt><span class="strong">Returns:</span></dt><dd>true if there was an uncompleted call to complete</dd></dl>
</li>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html b/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html
index 1e68b77..2cc3bbb 100644
--- a/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html
+++ b/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 -->
-<title>Partitioner (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>Partitioner (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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 (kafka 0.11.0.1 API)";
+ parent.document.title="Partitioner (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -87,12 +87,12 @@
<li class="blockList">
<dl>
<dt>All Superinterfaces:</dt>
-<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a>, <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a></dd>
+<dd>java.lang.AutoCloseable, java.io.Closeable, <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a></dd>
</dl>
<hr>
<br>
<pre>public interface <span class="strong">Partitioner</span>
-extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></pre>
+extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common">Configurable</a>, java.io.Closeable</pre>
<div class="block">Partitioner Interface</div>
</li>
</ul>
@@ -120,10 +120,10 @@ extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title
</tr>
<tr class="rowColor">
<td class="colFirst"><code>int</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Partitioner.html#partition(java.lang.String,%20java.lang.Object,%20byte[],%20java.lang.Object,%20byte[],%20org.apache.kafka.common.Cluster)">partition</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> key,
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Partitioner.html#partition(java.lang.String,%20java.lang.Object,%20byte[],%20java.lang.Object,%20byte[],%20org.apache.kafka.common.Cluster)">partition</a></strong>(java.lang.String topic,
+ java.lang.Object key,
byte[] keyBytes,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> value,
+ java.lang.Object value,
byte[] valueBytes,
<a href="../../../../../org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a> cluster)</code>
<div class="block">Compute the partition for the given record.</div>
@@ -157,10 +157,10 @@ extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title
<ul class="blockList">
<li class="blockList">
<h4>partition</h4>
-<pre>int partition(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> key,
+<pre>int partition(java.lang.String topic,
+ java.lang.Object key,
byte[] keyBytes,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> value,
+ java.lang.Object value,
byte[] valueBytes,
<a href="../../../../../org/apache/kafka/common/Cluster.html" title="class in org.apache.kafka.common">Cluster</a> cluster)</pre>
<div class="block">Compute the partition for the given record.</div>
@@ -177,9 +177,9 @@ extends <a href="../../../../../org/apache/kafka/common/Configurable.html" title
<div class="block">This is called when partitioner is closed.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true#close()" title="class or interface in java.lang">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></code></dd>
+<dd><code>close</code> in interface <code>java.lang.AutoCloseable</code></dd>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true#close()" title="class or interface in java.io">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></code></dd>
+<dd><code>close</code> in interface <code>java.io.Closeable</code></dd>
</dl>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/producer/Producer.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/clients/producer/Producer.html b/0110/javadoc/org/apache/kafka/clients/producer/Producer.html
index 87ce961..998097f 100644
--- a/0110/javadoc/org/apache/kafka/clients/producer/Producer.html
+++ b/0110/javadoc/org/apache/kafka/clients/producer/Producer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 -->
-<title>Producer (kafka 0.11.0.1 API)</title>
-<meta name="date" content="2017-09-05">
+<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 -->
+<title>Producer (kafka 0.11.0.2 API)</title>
+<meta name="date" content="2017-11-10">
<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 (kafka 0.11.0.1 API)";
+ parent.document.title="Producer (kafka 0.11.0.2 API)";
}
//-->
</script>
@@ -87,7 +87,7 @@
<li class="blockList">
<dl>
<dt>All Superinterfaces:</dt>
-<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></dd>
+<dd>java.lang.AutoCloseable, java.io.Closeable</dd>
</dl>
<dl>
<dt>All Known Implementing Classes:</dt>
@@ -96,7 +96,7 @@
<hr>
<br>
<pre>public interface <span class="strong">Producer<K,V></span>
-extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></pre>
+extends java.io.Closeable</pre>
<div class="block">The interface for the <a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer"><code>KafkaProducer</code></a></div>
<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer"><code>KafkaProducer</code></a>,
<a href="../../../../../org/apache/kafka/clients/producer/MockProducer.html" title="class in org.apache.kafka.clients.producer"><code>MockProducer</code></a></dd></dl>
@@ -139,7 +139,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#close(long,%20java.util.concurrent.TimeUnit)">close</a></strong>(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> unit)</code>
+ java.util.concurrent.TimeUnit unit)</code>
<div class="block">Tries to close the producer cleanly within the specified timeout.</div>
</td>
</tr>
@@ -162,25 +162,25 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
+<td class="colFirst"><code>java.util.Map<<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#metrics()">metrics</a></strong>()</code>
<div class="block">Return a map of metrics maintained by the producer</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>></code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic)</code>
+<td class="colFirst"><code>java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>></code></td>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(java.lang.String topic)</code>
<div class="block">Get a list of partitions for the given topic for custom partition assignment.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
+<td class="colFirst"><code>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord)">send</a></strong>(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record)</code>
<div class="block">Send the given record asynchronously and return a future which will eventually contain the response information.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
+<td class="colFirst"><code>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>></code></td>
<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#send(org.apache.kafka.clients.producer.ProducerRecord,%20org.apache.kafka.clients.producer.Callback)">send</a></strong>(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record,
<a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</code>
<div class="block">Send a record and invoke the given callback when the record has been acknowledged by the server</div>
@@ -188,8 +188,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)">sendOffsetsToTransaction</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> consumerGroupId)</code>
+<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/producer/Producer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)">sendOffsetsToTransaction</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
+ java.lang.String consumerGroupId)</code>
<div class="block">See <a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)"><code>KafkaProducer.sendOffsetsToTransaction(Map, String)</code></a></div>
</td>
</tr>
@@ -237,8 +237,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<ul class="blockList">
<li class="blockList">
<h4>sendOffsetsToTransaction</h4>
-<pre>void sendOffsetsToTransaction(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> consumerGroupId)
+<pre>void sendOffsetsToTransaction(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> offsets,
+ java.lang.String consumerGroupId)
throws <a href="../../../../../org/apache/kafka/common/errors/ProducerFencedException.html" title="class in org.apache.kafka.common.errors">ProducerFencedException</a></pre>
<div class="block">See <a href="../../../../../org/apache/kafka/clients/producer/KafkaProducer.html#sendOffsetsToTransaction(java.util.Map,%20java.lang.String)"><code>KafkaProducer.sendOffsetsToTransaction(Map, String)</code></a></div>
<dl><dt><span class="strong">Throws:</span></dt>
@@ -277,7 +277,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<ul class="blockList">
<li class="blockList">
<h4>send</h4>
-<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record)</pre>
+<pre>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record)</pre>
<div class="block">Send the given record asynchronously and return a future which will eventually contain the response information.</div>
<dl><dt><span class="strong">Parameters:</span></dt><dd><code>record</code> - The record to send</dd>
<dt><span class="strong">Returns:</span></dt><dd>A future which will eventually contain the response information</dd></dl>
@@ -289,8 +289,8 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<ul class="blockList">
<li class="blockList">
<h4>send</h4>
-<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html?is-external=true" title="class or interface in java.util.concurrent">Future</a><<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record,
- <a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</pre>
+<pre>java.util.concurrent.Future<<a href="../../../../../org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a>> send(<a href="../../../../../org/apache/kafka/clients/producer/ProducerRecord.html" title="class in org.apache.kafka.clients.producer">ProducerRecord</a><<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">K</a>,<a href="../../../../../org/apache/kafka/clients/producer/Producer.html" title="type parameter in Producer">V</a>> record,
+ <a href="../../../../../org/apache/kafka/clients/producer/Callback.html" title="interface in org.apache.kafka.clients.producer">Callback</a> callback)</pre>
<div class="block">Send a record and invoke the given callback when the record has been acknowledged by the server</div>
</li>
</ul>
@@ -310,7 +310,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<ul class="blockList">
<li class="blockList">
<h4>partitionsFor</h4>
-<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> topic)</pre>
+<pre>java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(java.lang.String topic)</pre>
<div class="block">Get a list of partitions for the given topic for custom partition assignment. The partition metadata will change
over time so this list should not be cached.</div>
</li>
@@ -321,7 +321,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<ul class="blockList">
<li class="blockList">
<h4>metrics</h4>
-<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
+<pre>java.util.Map<<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre>
<div class="block">Return a map of metrics maintained by the producer</div>
</li>
</ul>
@@ -335,9 +335,9 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<div class="block">Close this producer</div>
<dl>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true#close()" title="class or interface in java.lang">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true" title="class or interface in java.lang">AutoCloseable</a></code></dd>
+<dd><code>close</code> in interface <code>java.lang.AutoCloseable</code></dd>
<dt><strong>Specified by:</strong></dt>
-<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true#close()" title="class or interface in java.io">close</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true" title="class or interface in java.io">Closeable</a></code></dd>
+<dd><code>close</code> in interface <code>java.io.Closeable</code></dd>
</dl>
</li>
</ul>
@@ -348,7 +348,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html
<li class="blockList">
<h4>close</h4>
<pre>void close(long timeout,
- <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="class or interface in java.util.concurrent">TimeUnit</a> unit)</pre>
+ java.util.concurrent.TimeUnit unit)</pre>
<div class="block">Tries to close the producer cleanly within the specified timeout. If the close does not complete within the
timeout, fail any pending send requests and force close the producer.</div>
</li>