http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
b/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
index a6dbc59..407b764 100644
--- a/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
+++ b/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
@@ -2,15 +2,15 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:55 BST 2017
-->
-<title>KafkaConsumer (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:16 GMT 2017
-->
+<title>KafkaConsumer (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="KafkaConsumer (kafka 0.11.0.1 API)";
+ parent.document.title="KafkaConsumer (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.consumer.KafkaConsumer<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/consumer/Consumer.html"
title="interface in
org.apache.kafka.clients.consumer">Consumer</a><K,V></dd>
+<dd>java.io.Closeable, java.lang.AutoCloseable, <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html"
title="interface in
org.apache.kafka.clients.consumer">Consumer</a><K,V></dd>
</dl>
<hr>
<br>
<pre>public class <span class="strong">KafkaConsumer<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/consumer/Consumer.html"
title="interface in
org.apache.kafka.clients.consumer">Consumer</a><K,V></pre>
<div class="block">A client that consumes records from a Kafka cluster.
<p>
@@ -479,7 +479,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
The Kafka consumer is NOT thread-safe. All network I/O happens in the thread
of the application
making the call. It is the responsibility of the user to ensure that
multi-threaded access
- is properly synchronized. Un-synchronized access will result in <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/ConcurrentModificationException.html?is-external=true";
title="class or interface in
java.util"><code>ConcurrentModificationException</code></a>.
+ is properly synchronized. Un-synchronized access will result in
<code>ConcurrentModificationException</code>.
<p>
The only exception to this rule is <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#wakeup()"><code>wakeup()</code></a>,
which can safely be used from an external thread to
@@ -586,27 +586,27 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<th class="colOne" scope="col">Constructor and Description</th>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map)">KafkaConsumer</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="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/lang/Object.html?is-external=true";
title="class or interface in java.lang">Object</a>> configs)</code>
+<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map)">KafkaConsumer</a></strong>(java.util.Map<java.lang.String,java.lang.Object> configs)</code>
<div class="block">A consumer is instantiated by providing a set of key-value
pairs as configuration.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer</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="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/lang/Object.html?is-external=true";
title="class or interface in java.lang">Object</a>> configs,
+<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Map,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer</a></strong>(java.util.Map<java.lang.String,java.lang.Object> configs,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>> keyDeserializer,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>> valueDeserializer)</code>
<div class="block">A consumer is instantiated by providing a set of key-value
pairs as configuration, and a key and a value <a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization"><code>Deserializer</code></a>.</div>
</td>
</tr>
<tr class="altColor">
-<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties)">KafkaConsumer</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util">Properties</a> properties)</code>
-<div class="block">A consumer is instantiated by providing a <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util"><code>Properties</code></a> object as
configuration.</div>
+<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties)">KafkaConsumer</a></strong>(java.util.Properties properties)</code>
+<div class="block">A consumer is instantiated by providing a
<code>Properties</code> object as configuration.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util">Properties</a> properties,
+<td class="colOne"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#KafkaConsumer(java.util.Properties,%20org.apache.kafka.common.serialization.Deserializer,%20org.apache.kafka.common.serialization.Deserializer)">KafkaConsumer</a></strong>(java.util.Properties properties,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>> keyDeserializer,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>> valueDeserializer)</code>
-<div class="block">A consumer is instantiated by providing a <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util"><code>Properties</code></a> object as
configuration, and a
+<div class="block">A consumer is instantiated by providing a
<code>Properties</code> object as configuration, and a
key and a value <a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization"><code>Deserializer</code></a>.</div>
</td>
</tr>
@@ -627,19 +627,19 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)">assign</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)">assign</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Manually assign a list of partitions to this consumer.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>></code></td>
+<td class="colFirst"><code>java.util.Set<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>></code></td>
<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assignment()">assignment</a></strong>()</code>
<div class="block">Get the set of partitions currently assigned to this
consumer.</div>
</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in java.lang">Long</a>></code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#beginningOffsets(java.util.Collection)">beginningOffsets</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colFirst"><code>java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,java.lang.Long></code></td>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#beginningOffsets(java.util.Collection)">beginningOffsets</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Get the first offset for the given partitions.</div>
</td>
</tr>
@@ -652,7 +652,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.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 consumer cleanly within the specified
timeout.</div>
</td>
</tr>
@@ -664,7 +664,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync</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,
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)">commitAsync</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,
<a
href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html"
title="interface in
org.apache.kafka.clients.consumer">OffsetCommitCallback</a> callback)</code>
<div class="block">Commit the specified offsets for the specified list of
topics and partitions to Kafka.</div>
</td>
@@ -683,7 +683,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)">commitSync</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)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)">commitSync</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)</code>
<div class="block">Commit the specified offsets for the specified list of
topics and partitions.</div>
</td>
</tr>
@@ -695,43 +695,43 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in java.lang">Long</a>></code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#endOffsets(java.util.Collection)">endOffsets</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colFirst"><code>java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,java.lang.Long></code></td>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#endOffsets(java.util.Collection)">endOffsets</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Get the last offset for the given partitions.</div>
</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="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/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="colFirst"><code>java.util.Map<java.lang.String,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/consumer/KafkaConsumer.html#listTopics()">listTopics</a></strong>()</code>
<div class="block">Get metadata about partitions for all topics that the user
is authorized to view.</div>
</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/consumer/KafkaConsumer.html#metrics()">metrics</a></strong>()</code>
<div class="block">Get the metrics kept by the consumer</div>
</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="../../../../../org/apache/kafka/clients/consumer/OffsetAndTimestamp.html"
title="class in
org.apache.kafka.clients.consumer">OffsetAndTimestamp</a>></code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#offsetsForTimes(java.util.Map)">offsetsForTimes</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="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in
java.lang">Long</a>> timestampsToSearch)</code>
+<td class="colFirst"><code>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/OffsetAndTimestamp.html"
title="class in
org.apache.kafka.clients.consumer">OffsetAndTimestamp</a>></code></td>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#offsetsForTimes(java.util.Map)">offsetsForTimes</a></strong>(java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in
org.apache.kafka.common">TopicPartition</a>,java.lang.Long> timestampsToSearch)</code>
<div class="block">Look up the offsets for the given partitions by
timestamp.</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/consumer/KafkaConsumer.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/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(java.lang.String topic)</code>
<div class="block">Get metadata about the partitions for a given topic.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)">pause</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)">pause</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Suspend fetching from the requested partitions.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>></code></td>
+<td class="colFirst"><code>java.util.Set<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>></code></td>
<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#paused()">paused</a></strong>()</code>
<div class="block">Get the set of partitions that were previously paused by a
call to <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)"><code>pause(Collection)</code></a>.</div>
</td>
@@ -750,7 +750,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection)">resume</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection)">resume</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Resume specified partitions which have been paused with <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)"><code>pause(Collection)</code></a>.</div>
</td>
</tr>
@@ -763,25 +763,25 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToBeginning(java.util.Collection)">seekToBeginning</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToBeginning(java.util.Collection)">seekToBeginning</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Seek to the first offset for each of the given
partitions.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToEnd(java.util.Collection)">seekToEnd</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToEnd(java.util.Collection)">seekToEnd</a></strong>(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</code>
<div class="block">Seek to the last offset for each of the given
partitions.</div>
</td>
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)">subscribe</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</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>> topics)</code>
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)">subscribe</a></strong>(java.util.Collection<java.lang.String> topics)</code>
<div class="block">Subscribe to the given list of topics to get dynamically
assigned partitions.</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</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>> topics,
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(java.util.Collection<java.lang.String> topics,
<a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html"
title="interface in
org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</code>
<div class="block">Subscribe to the given list of topics to get dynamically
assigned partitions.</div>
@@ -789,13 +789,13 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
</tr>
<tr class="altColor">
<td class="colFirst"><code>void</code></td>
-<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true";
title="class or interface in java.util.regex">Pattern</a> pattern,
+<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(java.util.regex.Pattern pattern,
<a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html"
title="interface in
org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</code>
<div class="block">Subscribe to all topics matching specified pattern to get
dynamically assigned partitions.</div>
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</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>></code></td>
+<td class="colFirst"><code>java.util.Set<java.lang.String></code></td>
<td class="colLast"><code><strong><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscription()">subscription</a></strong>()</code>
<div class="block">Get the current subscription.</div>
</td>
@@ -817,8 +817,8 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.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>
@@ -840,7 +840,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>KafkaConsumer</h4>
-<pre>public KafkaConsumer(<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/lang/Object.html?is-external=true";
title="class or interface in java.lang">Object</a>> configs)</pre>
+<pre>public KafkaConsumer(java.util.Map<java.lang.String,java.lang.Object> configs)</pre>
<div class="block">A consumer is instantiated by providing a set of key-value
pairs as configuration. Valid configuration strings
are documented <a
href="http://kafka.apache.org/documentation.html#consumerconfigs"; >here</a>.
Values can be
either strings or objects of the appropriate type (for example a numeric
configuration would accept either the
@@ -856,7 +856,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>KafkaConsumer</h4>
-<pre>public KafkaConsumer(<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/lang/Object.html?is-external=true";
title="class or interface in java.lang">Object</a>> configs,
+<pre>public KafkaConsumer(java.util.Map<java.lang.String,java.lang.Object> configs,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>> keyDeserializer,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>> valueDeserializer)</pre>
<div class="block">A consumer is instantiated by providing a set of key-value
pairs as configuration, and a key and a value <a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization"><code>Deserializer</code></a>.
@@ -873,8 +873,8 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>KafkaConsumer</h4>
-<pre>public KafkaConsumer(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util">Properties</a> properties)</pre>
-<div class="block">A consumer is instantiated by providing a <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util"><code>Properties</code></a> object as
configuration.
+<pre>public KafkaConsumer(java.util.Properties properties)</pre>
+<div class="block">A consumer is instantiated by providing a
<code>Properties</code> object as configuration.
<p>
Valid configuration strings are documented at <a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerConfig.html"
title="class in
org.apache.kafka.clients.consumer"><code>ConsumerConfig</code></a></div>
<dl><dt><span
class="strong">Parameters:</span></dt><dd><code>properties</code> - The
consumer configuration properties</dd></dl>
@@ -886,10 +886,10 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockListLast">
<li class="blockList">
<h4>KafkaConsumer</h4>
-<pre>public KafkaConsumer(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util">Properties</a> properties,
+<pre>public KafkaConsumer(java.util.Properties properties,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>> keyDeserializer,
<a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization">Deserializer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>> valueDeserializer)</pre>
-<div class="block">A consumer is instantiated by providing a <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true";
title="class or interface in java.util"><code>Properties</code></a> object as
configuration, and a
+<div class="block">A consumer is instantiated by providing a
<code>Properties</code> object as configuration, and a
key and a value <a
href="../../../../../org/apache/kafka/common/serialization/Deserializer.html"
title="interface in
org.apache.kafka.common.serialization"><code>Deserializer</code></a>.
<p>
Valid configuration strings are documented at <a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerConfig.html"
title="class in
org.apache.kafka.clients.consumer"><code>ConsumerConfig</code></a></div>
@@ -912,7 +912,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>assignment</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> assignment()</pre>
+<pre>public java.util.Set<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> assignment()</pre>
<div class="block">Get the set of partitions currently assigned to this
consumer. If subscription happened by directly assigning
partitions using <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)"><code>assign(Collection)</code></a>
then this will simply return the same partitions that
were assigned. If topic subscription was used, then this will give the set of
topic partitions currently assigned
@@ -930,7 +930,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>subscription</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</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>> subscription()</pre>
+<pre>public java.util.Set<java.lang.String> subscription()</pre>
<div class="block">Get the current subscription. Will return the same topics
used in the most recent call to
<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)"><code>subscribe(Collection,
ConsumerRebalanceListener)</code></a>, or an empty set if no such call has
been made.</div>
<dl>
@@ -945,7 +945,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>subscribe</h4>
-<pre>public void subscribe(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</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>> topics,
+<pre>public void subscribe(java.util.Collection<java.lang.String> topics,
<a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html"
title="interface in
org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</pre>
<div class="block">Subscribe to the given list of topics to get dynamically
assigned partitions. <b>Topic subscriptions are not incremental. This list
will replace the current
@@ -975,7 +975,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dt><span class="strong">Parameters:</span></dt><dd><code>topics</code> - The
list of topics to subscribe to</dd><dd><code>listener</code> - Non-null
listener instance to get notifications on partition assignment/revocation for
the
subscribed topics</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
If topics is null or contains null or empty elements</dd><dt><span
class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)"><code>subscribe(Collection,
ConsumerRebalanceListener)</code></a></dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - If topics is null or
contains null or empty elements</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)"><code>subscribe(Collection,
ConsumerRebalanceListener)</code></a></dd></dl>
</li>
</ul>
<a name="subscribe(java.util.Collection)">
@@ -984,7 +984,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>subscribe</h4>
-<pre>public void subscribe(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</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>> topics)</pre>
+<pre>public void subscribe(java.util.Collection<java.lang.String> topics)</pre>
<div class="block">Subscribe to the given list of topics to get dynamically
assigned partitions.
<b>Topic subscriptions are not incremental. This list will replace the current
assignment (if there is one).</b> It is not possible to combine topic
subscription with group management
@@ -1003,7 +1003,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dd><code><a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#subscribe(java.util.Collection)">subscribe</a></code> in
interface <code><a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html"
title="interface in org.apache.kafka.clients.consumer">Consumer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>,<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>></code></dd>
<dt><span class="strong">Parameters:</span></dt><dd><code>topics</code> - The
list of topics to subscribe to</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
If topics is null or contains null or empty elements</dd><dt><span
class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)"><code>subscribe(Collection)</code></a></dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - If topics is null or
contains null or empty elements</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)"><code>subscribe(Collection)</code></a></dd></dl>
</li>
</ul>
<a name="subscribe(java.util.regex.Pattern,
org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">
@@ -1012,7 +1012,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>subscribe</h4>
-<pre>public void subscribe(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true";
title="class or interface in java.util.regex">Pattern</a> pattern,
+<pre>public void subscribe(java.util.regex.Pattern pattern,
<a
href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html"
title="interface in
org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</pre>
<div class="block">Subscribe to all topics matching specified pattern to get
dynamically assigned partitions. The pattern matching will be done periodically
against topics
existing at the time of check.
@@ -1033,7 +1033,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dt><span class="strong">Parameters:</span></dt><dd><code>pattern</code> -
Pattern to subscribe to</dd><dd><code>listener</code> - Non-null listener
instance to get notifications on partition assignment/revocation for the
subscribed topics</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
If pattern is null</dd><dt><span class="strong">See Also:</span></dt><dd><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></dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - If pattern is
null</dd><dt><span class="strong">See Also:</span></dt><dd><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></dd></dl>
</li>
</ul>
<a name="unsubscribe()">
@@ -1057,7 +1057,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>assign</h4>
-<pre>public void assign(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public void assign(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Manually assign a list of partitions to this consumer. This
interface does not allow for incremental assignment
and will replace the previous assignment (if there is one).
@@ -1073,7 +1073,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<dd><code><a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#assign(java.util.Collection)">assign</a></code> in
interface <code><a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html"
title="interface in org.apache.kafka.clients.consumer">Consumer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>,<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>></code></dd>
<dt><span class="strong">Parameters:</span></dt><dd><code>partitions</code> -
The list of partitions to assign this consumer</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
If partitions is null or contains null or empty topics</dd><dt><span
class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)"><code>assign(Collection)</code></a></dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - If partitions is null or
contains null or empty topics</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)"><code>assign(Collection)</code></a></dd></dl>
</li>
</ul>
<a name="poll(long)">
@@ -1107,8 +1107,8 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
topics or to the configured groupId</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 (e.g. invalid groupId or
session timeout, errors deserializing key/value pairs, or any new
error cases in future versions)</dd>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
if the timeout value is negative</dd>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalStateException.html?is-external=true";
title="class or interface in java.lang">IllegalStateException</a></code> - if
the consumer is not subscribed to any topics or manually assigned any
+<dd><code>java.lang.IllegalArgumentException</code> - if the timeout value is
negative</dd>
+<dd><code>java.lang.IllegalStateException</code> - if the consumer is not
subscribed to any topics or manually assigned any
partitions to consume from</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll(long)</code></a></dd></dl>
</li>
</ul>
@@ -1141,7 +1141,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<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 topic or to the
configured groupId</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 (e.g. if offset metadata
- is too large or if the committed offset is
invalid).</dd><dt><span class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()"><code>commitSync()</code></a></dd></dl>
+ is too large or if the topic does not exist).</dd><dt><span
class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync()"><code>commitSync()</code></a></dd></dl>
</li>
</ul>
<a name="commitSync(java.util.Map)">
@@ -1150,7 +1150,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>commitSync</h4>
-<pre>public void commitSync(<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)</pre>
+<pre>public void commitSync(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)</pre>
<div class="block">Commit the specified offsets for the specified list of
topics and partitions.
<p>
This commits offsets to Kafka. The offsets committed using this API will be
used on the first fetch after every
@@ -1174,8 +1174,9 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
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 topic or to the
configured groupId</dd>
+<dd><code>java.lang.IllegalArgumentException</code> - if the committed offset
is negative</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 (e.g. if offset metadata
- is too large or if the committed offset is
invalid).</dd><dt><span class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)"><code>commitSync(Map)</code></a></dd></dl>
+ is too large or if the topic does not exist).</dd><dt><span
class="strong">See Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)"><code>commitSync(Map)</code></a></dd></dl>
</li>
</ul>
<a name="commitAsync()">
@@ -1220,7 +1221,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>commitAsync</h4>
-<pre>public void commitAsync(<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,
+<pre>public void commitAsync(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,
<a
href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html"
title="interface in
org.apache.kafka.clients.consumer">OffsetCommitCallback</a> callback)</pre>
<div class="block">Commit the specified offsets for the specified list of
topics and partitions to Kafka.
<p>
@@ -1261,7 +1262,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>seekToBeginning</h4>
-<pre>public void seekToBeginning(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public void seekToBeginning(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Seek to the first offset for each of the given partitions.
This function evaluates lazily, seeking to the
first offset in all partitions only when <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll(long)</code></a>
or <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#position(org.apache.kafka.common.TopicPartition)"><code>position(TopicPartition)</code></a>
are called.
If no partition is provided, seek to the first offset for all of the
currently assigned partitions.</div>
@@ -1277,7 +1278,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>seekToEnd</h4>
-<pre>public void seekToEnd(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public void seekToEnd(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Seek to the last offset for each of the given partitions.
This function evaluates lazily, seeking to the
final offset in all partitions only when <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll(long)</code></a>
or <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#position(org.apache.kafka.common.TopicPartition)"><code>position(TopicPartition)</code></a>
are called.
If no partition is provided, seek to the final offset for all of the
currently assigned partitions.
@@ -1347,7 +1348,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.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>,? extends <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>,? extends <a
href="../../../../../org/apache/kafka/common/Metric.html" title="interface in
org.apache.kafka.common">Metric</a>> metrics()</pre>
<div class="block">Get the metrics kept by the consumer</div>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -1361,7 +1362,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.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">Get metadata about the partitions for a given topic. This
method will issue a remote call to the server if it
does not already have any metadata about the given topic.</div>
<dl>
@@ -1386,7 +1387,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>listTopics</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="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/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>>> listTopics()</pre>
+<pre>public java.util.Map<java.lang.String,java.util.List<<a
href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class
in org.apache.kafka.common">PartitionInfo</a>>> listTopics()</pre>
<div class="block">Get metadata about partitions for all topics that the user
is authorized to view. This method will issue a
remote call to the server.</div>
<dl>
@@ -1409,7 +1410,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>pause</h4>
-<pre>public void pause(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public void pause(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Suspend fetching from the requested partitions. Future
calls to <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll(long)</code></a>
will not return
any records from these partitions until they have been resumed using <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection)"><code>resume(Collection)</code></a>.
Note that this method does not affect partition subscription. In particular,
it does not cause a group
@@ -1426,7 +1427,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>resume</h4>
-<pre>public void resume(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public void resume(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Resume specified partitions which have been paused with <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)"><code>pause(Collection)</code></a>.
New calls to
<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)"><code>poll(long)</code></a>
will return records from these partitions if there are any to be fetched.
If the partitions were not previously paused, this method is a no-op.</div>
@@ -1442,7 +1443,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>paused</h4>
-<pre>public <a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true";
title="class or interface in java.util">Set</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> paused()</pre>
+<pre>public java.util.Set<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> paused()</pre>
<div class="block">Get the set of partitions that were previously paused by a
call to <a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)"><code>pause(Collection)</code></a>.</div>
<dl>
<dt><strong>Specified by:</strong></dt>
@@ -1456,7 +1457,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>offsetsForTimes</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="../../../../../org/apache/kafka/clients/consumer/OffsetAndTimestamp.html"
title="class in
org.apache.kafka.clients.consumer">OffsetAndTimestamp</a>> offsetsForTimes(<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="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in
java.lang">Long</a>> timestampsToSearch)</pre>
+<pre>public 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/OffsetAndTimestamp.html"
title="class in
org.apache.kafka.clients.consumer">OffsetAndTimestamp</a>> offsetsForTimes(java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in
org.apache.kafka.common">TopicPartition</a>,java.lang.Long> timestampsToSearch)</pre>
<div class="block">Look up the offsets for the given partitions by timestamp.
The returned offset for each partition is the
earliest offset whose timestamp is greater than or equal to the given
timestamp in the corresponding partition.
@@ -1473,7 +1474,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
than or equal to the target timestamp. <code>null</code> will be
returned for the partition if there is no
such message.</dd>
<dt><span class="strong">Throws:</span></dt>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
if the target timestamp is negative.</dd>
+<dd><code>java.lang.IllegalArgumentException</code> - if the target timestamp
is negative.</dd>
<dd><code><a
href="../../../../../org/apache/kafka/common/errors/UnsupportedVersionException.html"
title="class in
org.apache.kafka.common.errors">UnsupportedVersionException</a></code> - if the
broker does not support looking up
the offsets by timestamp.</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#offsetsForTimes(java.util.Map)"><code>offsetsForTimes(java.util.Map)</code></a></dd></dl>
</li>
@@ -1484,7 +1485,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>beginningOffsets</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in java.lang">Long</a>> beginningOffsets(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in
org.apache.kafka.common">TopicPartition</a>,java.lang.Long> beginningOffsets(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Get the first offset for the given partitions.
<p>
Notice that this method may block indefinitely if the partition does not
exist.
@@ -1502,7 +1503,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
<ul class="blockList">
<li class="blockList">
<h4>endOffsets</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/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>,<a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true";
title="class or interface in java.lang">Long</a>> endOffsets(<a
href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true";
title="class or interface in java.util">Collection</a><<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
+<pre>public java.util.Map<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in
org.apache.kafka.common">TopicPartition</a>,java.lang.Long> endOffsets(java.util.Collection<<a
href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class
in org.apache.kafka.common">TopicPartition</a>> partitions)</pre>
<div class="block">Get the last offset for the given partitions. The last
offset of a partition is the offset of the upcoming
message, i.e. the offset of the last available message + 1.
<p>
@@ -1533,9 +1534,9 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
cannot be used to interrupt close.</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/consumer/Consumer.html#close()">close</a></code> in
interface <code><a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.html"
title="interface in org.apache.kafka.clients.consumer">Consumer</a><<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">K</a>,<a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html"
title="type parameter in KafkaConsumer">V</a>></code></dd>
<dt><span class="strong">Throws:</span></dt>
@@ -1550,7 +1551,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.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">Tries to close the consumer cleanly within the specified
timeout. This method waits up to
<code>timeout</code> for the consumer to complete pending commits and leave
the group.
If auto-commit is enabled, this will commit the current offsets if possible
within the
@@ -1564,7 +1565,7 @@ implements <a
href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht
non-negative. Specifying a timeout of zero means do not wait
for pending requests to complete.</dd><dd><code>timeUnit</code> - The time unit
for the <code>timeout</code></dd>
<dt><span class="strong">Throws:</span></dt>
<dd><code><a
href="../../../../../org/apache/kafka/common/errors/InterruptException.html"
title="class in org.apache.kafka.common.errors">InterruptException</a></code> -
If the thread is interrupted before or while this function is called</dd>
-<dd><code><a
href="http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalArgumentException.html?is-external=true";
title="class or interface in java.lang">IllegalArgumentException</a></code> -
If the <code>timeout</code> is negative.</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#close(long,%20java.util.concurrent.TimeUnit)"><code>close(long,
TimeUnit)</code></a></dd></dl>
+<dd><code>java.lang.IllegalArgumentException</code> - If the
<code>timeout</code> is negative.</dd><dt><span class="strong">See
Also:</span></dt><dd><a
href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#close(long,%20java.util.concurrent.TimeUnit)"><code>close(long,
TimeUnit)</code></a></dd></dl>
</li>
</ul>
<a name="wakeup()">
