http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html b/0100/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html index 89a8726..879801b 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/MockConsumer.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:37 PDT 2016 --> -<title>MockConsumer (clients 0.10.0.0 API)</title> -<meta name="date" content="2016-05-17"> +<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:04 BST 2016 --> +<title>MockConsumer (kafka 0.10.0.0 API)</title> +<meta name="date" content="2016-05-19"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MockConsumer (clients 0.10.0.0 API)"; + parent.document.title="MockConsumer (kafka 0.10.0.0 API)"; } //--> </script> @@ -83,7 +83,7 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li>java.lang.Object</li> +<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> <ul class="inheritance"> <li>org.apache.kafka.clients.consumer.MockConsumer<K,V></li> @@ -95,12 +95,12 @@ <li class="blockList"> <dl> <dt>All Implemented Interfaces:</dt> -<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> +<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> </dl> <hr> <br> <pre>public class <span class="strong">MockConsumer<K,V></span> -extends java.lang.Object +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> 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 mock of the <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><code>Consumer</code></a> interface you can use for testing code that uses Kafka. This class is <i> not threadsafe </i>. However, you can use the <a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#schedulePollTask(java.lang.Runnable)"><code>schedulePollTask(Runnable)</code></a> method to write multithreaded tests @@ -147,10 +147,10 @@ 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/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="altColor"> -<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="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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#assignment()">assignment</a></strong>()</code> </td> </tr> <tr class="rowColor"> @@ -167,7 +167,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/MockConsumer.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, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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, <a href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html" title="interface in org.apache.kafka.clients.consumer">OffsetCommitCallback</a> callback)</code> </td> </tr> <tr class="rowColor"> @@ -180,30 +180,30 @@ 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/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="altColor"> <td class="colFirst"><code><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/consumer/MockConsumer.html#committed(org.apache.kafka.common.TopicPartition)">committed</a></strong>(<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a> partition)</code> </td> </tr> <tr class="rowColor"> -<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="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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#listTopics()">listTopics</a></strong>()</code> </td> </tr> <tr class="altColor"> -<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="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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#metrics()">metrics</a></strong>()</code> </td> </tr> <tr class="rowColor"> -<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/MockConsumer.html#partitionsFor(java.lang.String)">partitionsFor</a></strong>(java.lang.String topic)</code> </td> +<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/MockConsumer.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> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="rowColor"> -<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="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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#paused()">paused</a></strong>()</code> </td> </tr> <tr class="altColor"> @@ -216,13 +216,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/MockConsumer.html#rebalance(java.util.Collection)">rebalance</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> newAssignment)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#rebalance(java.util.Collection)">rebalance</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>> newAssignment)</code> <div class="block">Simulate a rebalance event.</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/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> @@ -230,7 +230,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/MockConsumer.html#schedulePollTask(java.lang.Runnable)">schedulePollTask</a></strong>(java.lang.Runnable task)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#schedulePollTask(java.lang.Runnable)">schedulePollTask</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a> task)</code> <div class="block">Schedule a task to be executed during a poll().</div> </td> </tr> @@ -241,11 +241,11 @@ 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/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> @@ -253,20 +253,20 @@ 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/MockConsumer.html#subscribe(java.util.Collection)">subscribe</a></strong>(java.util.Collection<java.lang.String> topics)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(java.util.Collection<java.lang.String> topics, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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, <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</code> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)">subscribe</a></strong>(java.util.regex.Pattern pattern, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.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, <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>java.util.Set<java.lang.String></code></td> +<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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#subscription()">subscription</a></strong>()</code> </td> </tr> <tr class="altColor"> @@ -275,16 +275,16 @@ 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/MockConsumer.html#updateBeginningOffsets(java.util.Map)">updateBeginningOffsets</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> newOffsets)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#updateBeginningOffsets(java.util.Map)">updateBeginningOffsets</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>> newOffsets)</code> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#updateEndOffsets(java.util.Map)">updateEndOffsets</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> newOffsets)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#updateEndOffsets(java.util.Map)">updateEndOffsets</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>> newOffsets)</code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#updatePartitions(java.lang.String,%20java.util.List)">updatePartitions</a></strong>(java.lang.String topic, - java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitions)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#updatePartitions(java.lang.String,%20java.util.List)">updatePartitions</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/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>> partitions)</code> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> @@ -295,8 +295,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.Object</h3> -<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li> +<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> </ul> </li> </ul> @@ -335,7 +335,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>assignment</h4> -<pre>public java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> assignment()</pre> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#assignment()">assignment</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -348,7 +348,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>rebalance</h4> -<pre>public void rebalance(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> newAssignment)</pre> +<pre>public void rebalance(<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>> newAssignment)</pre> <div class="block">Simulate a rebalance event.</div> </li> </ul> @@ -358,7 +358,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>subscription</h4> -<pre>public java.util.Set<java.lang.String> subscription()</pre> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#subscription()">subscription</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -371,7 +371,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>public void subscribe(java.util.Collection<java.lang.String> topics)</pre> +<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> <dl> <dt><strong>Specified by:</strong></dt> <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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -384,7 +384,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>public void subscribe(java.util.regex.Pattern pattern, +<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, <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</pre> <dl> <dt><strong>Specified by:</strong></dt> @@ -398,7 +398,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>public void subscribe(java.util.Collection<java.lang.String> topics, +<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, <a href="../../../../../org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer">ConsumerRebalanceListener</a> listener)</pre> <dl> <dt><strong>Specified by:</strong></dt> @@ -412,7 +412,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>assign</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -469,7 +469,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>commitAsync</h4> -<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, +<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, <a href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html" title="interface in org.apache.kafka.clients.consumer">OffsetCommitCallback</a> callback)</pre> <dl> <dt><strong>Specified by:</strong></dt> @@ -483,7 +483,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>commitSync</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map)">commitSync</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -575,7 +575,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>seekToBeginning</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#seekToBeginning(java.util.Collection)">seekToBeginning</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -588,7 +588,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>updateBeginningOffsets</h4> -<pre>public void updateBeginningOffsets(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,java.lang.Long> newOffsets)</pre> +<pre>public void updateBeginningOffsets(<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>> newOffsets)</pre> </li> </ul> <a name="seekToEnd(java.util.Collection)"> @@ -597,7 +597,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>seekToEnd</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#seekToEnd(java.util.Collection)">seekToEnd</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -610,7 +610,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>updateEndOffsets</h4> -<pre>public void updateEndOffsets(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,java.lang.Long> newOffsets)</pre> +<pre>public void updateEndOffsets(<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>> newOffsets)</pre> </li> </ul> <a name="metrics()"> @@ -619,7 +619,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>metrics</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#metrics()">metrics</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -632,7 +632,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>partitionsFor</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#partitionsFor(java.lang.String)">partitionsFor</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -645,7 +645,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>listTopics</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#listTopics()">listTopics</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -658,8 +658,8 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>updatePartitions</h4> -<pre>public void updatePartitions(java.lang.String topic, - java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitions)</pre> +<pre>public void updatePartitions(<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/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>> partitions)</pre> </li> </ul> <a name="pause(java.util.Collection)"> @@ -668,7 +668,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>pause</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#pause(java.util.Collection)">pause</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -681,7 +681,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>resume</h4> -<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> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#resume(java.util.Collection)">resume</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> @@ -697,9 +697,9 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <pre>public void close()</pre> <dl> <dt><strong>Specified by:</strong></dt> -<dd><code>close</code> in interface <code>java.io.Closeable</code></dd> +<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> <dt><strong>Specified by:</strong></dt> -<dd><code>close</code> in interface <code>java.lang.AutoCloseable</code></dd> +<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> <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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd> <dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#close()"><code>KafkaConsumer.close()</code></a></dd></dl> @@ -733,7 +733,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockList"> <li class="blockList"> <h4>schedulePollTask</h4> -<pre>public void schedulePollTask(java.lang.Runnable task)</pre> +<pre>public void schedulePollTask(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a> task)</pre> <div class="block">Schedule a task to be executed during a poll(). One enqueued task will be executed per <a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html#poll(long)"><code>poll(long)</code></a> invocation. You can use this repeatedly to mock out multiple responses to poll invocations.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>task</code> - the task to be executed</dd></dl> @@ -754,7 +754,7 @@ implements <a href="../../../../../org/apache/kafka/clients/consumer/Consumer.ht <ul class="blockListLast"> <li class="blockList"> <h4>paused</h4> -<pre>public java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> paused()</pre> +<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> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.html#paused()">paused</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/MockConsumer.html" title="type parameter in MockConsumer">K</a>,<a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="type parameter in MockConsumer">V</a>></code></dd>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html b/0100/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html index 3cf0233..95af3b3 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:37 PDT 2016 --> -<title>NoOffsetForPartitionException (clients 0.10.0.0 API)</title> -<meta name="date" content="2016-05-17"> +<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:04 BST 2016 --> +<title>NoOffsetForPartitionException (kafka 0.10.0.0 API)</title> +<meta name="date" content="2016-05-19"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="NoOffsetForPartitionException (clients 0.10.0.0 API)"; + parent.document.title="NoOffsetForPartitionException (kafka 0.10.0.0 API)"; } //--> </script> @@ -83,16 +83,16 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li>java.lang.Object</li> +<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> <ul class="inheritance"> -<li>java.lang.Throwable</li> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">java.lang.Throwable</a></li> <li> <ul class="inheritance"> -<li>java.lang.Exception</li> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">java.lang.Exception</a></li> <li> <ul class="inheritance"> -<li>java.lang.RuntimeException</li> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/RuntimeException.html?is-external=true"; title="class or interface in java.lang">java.lang.RuntimeException</a></li> <li> <ul class="inheritance"> <li><a href="../../../../../org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">org.apache.kafka.common.KafkaException</a></li> @@ -120,7 +120,7 @@ <li class="blockList"> <dl> <dt>All Implemented Interfaces:</dt> -<dd>java.io.Serializable</dd> +<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a></dd> </dl> <hr> <br> @@ -169,7 +169,7 @@ extends <a href="../../../../../org/apache/kafka/clients/consumer/InvalidOffsetE <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html#partition()">partition</a></strong>()</code> </td> </tr> <tr class="rowColor"> -<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="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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html#partitions()">partitions</a></strong>()</code> </td> </tr> </table> @@ -177,15 +177,15 @@ extends <a href="../../../../../org/apache/kafka/clients/consumer/InvalidOffsetE <li class="blockList"><a name="methods_inherited_from_class_java.lang.Throwable"> <!-- --> </a> -<h3>Methods inherited from class java.lang.Throwable</h3> -<code>addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString</code></li> +<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a></h3> +<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#addSuppressed(java.lang.Throwable)" title="class or interface in java.lang">addSuppressed</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#fillInStackTrace()" title="class or interface in java.lang">fillInStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#getCause()" title="class or interface in java.lang">getCause</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#getLocalizedMessage()" title="class or interface in java.lang">getLocalizedMessage</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#getMessage()" title="class or interface in java.lang">getMessage</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#getStackTrace()" title="class or inter face in java.lang">getStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#getSuppressed()" title="class or interface in java.lang">getSuppressed</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#initCause(java.lang.Throwable)" title="class or interface in java.lang">initCause</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace()" title="class or interface in java.lang">printStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace(java.io.PrintStream)" title="class or interface in java.lang">printStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#printStackTrace(java.io.PrintWriter)" title="class or interface in java.lang">printStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lan g/Throwable.html?is-external=true#setStackTrace(java.lang.StackTraceElement[])" title="class or interface in java.lang">setStackTrace</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true#toString()" title="class or interface in java.lang">toString</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.Object</h3> -<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait</code></li> +<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#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> </ul> </li> </ul> @@ -233,7 +233,7 @@ extends <a href="../../../../../org/apache/kafka/clients/consumer/InvalidOffsetE <ul class="blockListLast"> <li class="blockList"> <h4>partitions</h4> -<pre>public java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions()</pre> +<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>> partitions()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/clients/consumer/InvalidOffsetException.html#partitions()">partitions</a></code> in class <code><a href="../../../../../org/apache/kafka/clients/consumer/InvalidOffsetException.html" title="class in org.apache.kafka.clients.consumer">InvalidOffsetException</a></code></dd> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html index a879ddd..ba220ac 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:37 PDT 2016 --> -<title>OffsetAndMetadata (clients 0.10.0.0 API)</title> -<meta name="date" content="2016-05-17"> +<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:04 BST 2016 --> +<title>OffsetAndMetadata (kafka 0.10.0.0 API)</title> +<meta name="date" content="2016-05-19"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="OffsetAndMetadata (clients 0.10.0.0 API)"; + parent.document.title="OffsetAndMetadata (kafka 0.10.0.0 API)"; } //--> </script> @@ -83,7 +83,7 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li>java.lang.Object</li> +<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> <ul class="inheritance"> <li>org.apache.kafka.clients.consumer.OffsetAndMetadata</li> @@ -95,13 +95,13 @@ <li class="blockList"> <dl> <dt>All Implemented Interfaces:</dt> -<dd>java.io.Serializable</dd> +<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a></dd> </dl> <hr> <br> <pre>public class <span class="strong">OffsetAndMetadata</span> -extends java.lang.Object -implements java.io.Serializable</pre> +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> +implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a></pre> <div class="block">The Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed. This can be useful (for example) to store information about which node made the commit, what time the commit was made, etc.</div> @@ -130,7 +130,7 @@ implements java.io.Serializable</pre> </tr> <tr class="rowColor"> <td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#OffsetAndMetadata(long,%20java.lang.String)">OffsetAndMetadata</a></strong>(long offset, - java.lang.String metadata)</code> + <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> metadata)</code> <div class="block">Construct a new OffsetAndMetadata object for committing through <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer"><code>KafkaConsumer</code></a>.</div> </td> </tr> @@ -151,14 +151,14 @@ implements java.io.Serializable</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>boolean</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#equals(java.lang.Object)">equals</a></strong>(java.lang.Object o)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#equals(java.lang.Object)">equals</a></strong>(<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> o)</code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#hashCode()">hashCode</a></strong>()</code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>java.lang.String</code></td> +<td class="colFirst"><code><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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#metadata()">metadata</a></strong>()</code> </td> </tr> <tr class="rowColor"> @@ -166,7 +166,7 @@ implements java.io.Serializable</pre> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#offset()">offset</a></strong>()</code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>java.lang.String</code></td> +<td class="colFirst"><code><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="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html#toString()">toString</a></strong>()</code> </td> </tr> </table> @@ -174,8 +174,8 @@ implements java.io.Serializable</pre> <li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.Object</h3> -<code>clone, finalize, getClass, notify, notifyAll, wait, wait, wait</code></li> +<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#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#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#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-ex ternal=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> </ul> </li> </ul> @@ -198,7 +198,7 @@ implements java.io.Serializable</pre> <li class="blockList"> <h4>OffsetAndMetadata</h4> <pre>public OffsetAndMetadata(long offset, - java.lang.String metadata)</pre> + <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> metadata)</pre> <div class="block">Construct a new OffsetAndMetadata object for committing through <a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer"><code>KafkaConsumer</code></a>.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>offset</code> - The offset to be committed</dd><dd><code>metadata</code> - Non-null metadata</dd></dl> </li> @@ -238,7 +238,7 @@ implements java.io.Serializable</pre> <ul class="blockList"> <li class="blockList"> <h4>metadata</h4> -<pre>public java.lang.String metadata()</pre> +<pre>public <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> metadata()</pre> </li> </ul> <a name="equals(java.lang.Object)"> @@ -247,10 +247,10 @@ implements java.io.Serializable</pre> <ul class="blockList"> <li class="blockList"> <h4>equals</h4> -<pre>public boolean equals(java.lang.Object o)</pre> +<pre>public boolean equals(<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> o)</pre> <dl> <dt><strong>Overrides:</strong></dt> -<dd><code>equals</code> in class <code>java.lang.Object</code></dd> +<dd><code><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></code> in class <code><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></code></dd> </dl> </li> </ul> @@ -263,7 +263,7 @@ implements java.io.Serializable</pre> <pre>public int hashCode()</pre> <dl> <dt><strong>Overrides:</strong></dt> -<dd><code>hashCode</code> in class <code>java.lang.Object</code></dd> +<dd><code><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></code> in class <code><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></code></dd> </dl> </li> </ul> @@ -273,10 +273,10 @@ implements java.io.Serializable</pre> <ul class="blockListLast"> <li class="blockList"> <h4>toString</h4> -<pre>public java.lang.String toString()</pre> +<pre>public <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> toString()</pre> <dl> <dt><strong>Overrides:</strong></dt> -<dd><code>toString</code> in class <code>java.lang.Object</code></dd> +<dd><code><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></code> in class <code><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></code></dd> </dl> </li> </ul> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html index 9994bdb..efb994b 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/OffsetCommitCallback.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:37 PDT 2016 --> -<title>OffsetCommitCallback (clients 0.10.0.0 API)</title> -<meta name="date" content="2016-05-17"> +<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:04 BST 2016 --> +<title>OffsetCommitCallback (kafka 0.10.0.0 API)</title> +<meta name="date" content="2016-05-19"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="OffsetCommitCallback (clients 0.10.0.0 API)"; + parent.document.title="OffsetCommitCallback (kafka 0.10.0.0 API)"; } //--> </script> @@ -110,8 +110,8 @@ </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html#onComplete(java.util.Map,%20java.lang.Exception)">onComplete</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.Exception exception)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/OffsetCommitCallback.html#onComplete(java.util.Map,%20java.lang.Exception)">onComplete</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/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> exception)</code> <div class="block">A callback method the user can implement to provide asynchronous handling of commit request completion.</div> </td> </tr> @@ -136,8 +136,8 @@ <ul class="blockListLast"> <li class="blockList"> <h4>onComplete</h4> -<pre>void onComplete(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.Exception exception)</pre> +<pre>void onComplete(<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/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a> exception)</pre> <div class="block">A callback method the user can implement to provide asynchronous handling of commit request completion. This method will be called when the commit request sent to the server has been acknowledged.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>offsets</code> - A map of the offsets and associated metadata that this callback applies to</dd><dd><code>exception</code> - The exception thrown during processing of the request, or null if the commit completed successfully</dd>
