http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/index.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/index.html b/0100/javadoc/index.html index 9d662d5..4ad1e23 100644 --- a/0100/javadoc/index.html +++ b/0100/javadoc/index.html @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc on Tue May 17 21:36:38 PDT 2016 --> -<title>clients 0.10.0.0 API</title> +<!-- Generated by javadoc on Thu May 19 00:52:06 BST 2016 --> +<title>kafka 0.10.0.0 API</title> <script type="text/javascript"> targetPage = "" + window.location.search; if (targetPage != "" && targetPage != "undefined")
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/kafka/javaapi/consumer/ConsumerConnector.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/kafka/javaapi/consumer/ConsumerConnector.html b/0100/javadoc/kafka/javaapi/consumer/ConsumerConnector.html deleted file mode 100644 index dbf5ff3..0000000 --- a/0100/javadoc/kafka/javaapi/consumer/ConsumerConnector.html +++ /dev/null @@ -1,361 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>ConsumerConnector (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> -<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="ConsumerConnector (core 0.10.0.0 API)"; - } -//--> -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar_top"> -<!-- --> -</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev Class</li> -<li><a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer"><span class="strong">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/ConsumerConnector.html" target="_top">Frames</a></li> -<li><a href="ConsumerConnector.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_detail">Method</a></li> -</ul> -</div> -<a name="skip-navbar_top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<!-- ======== START OF CLASS DATA ======== --> -<div class="header"> -<div class="subTitle">kafka.javaapi.consumer</div> -<h2 title="Interface ConsumerConnector" class="title">Interface ConsumerConnector</h2> -</div> -<div class="contentContainer"> -<div class="description"> -<ul class="blockList"> -<li class="blockList"> -<hr> -<br> -<pre>public interface <span class="strong">ConsumerConnector</span></pre> -</li> -</ul> -</div> -<div class="summary"> -<ul class="blockList"> -<li class="blockList"> -<!-- ========== METHOD SUMMARY =========== --> -<ul class="blockList"> -<li class="blockList"><a name="method_summary"> -<!-- --> -</a> -<h3>Method Summary</h3> -<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span>Methods</span><span class="tabEnd"> </span></caption> -<tr> -<th class="colFirst" scope="col">Modifier and Type</th> -<th class="colLast" scope="col">Method and Description</th> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#commitOffsets()">commitOffsets</a></strong>()</code> -<div class="block">Commit the offsets of all broker partitions connected by this connector.</div> -</td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#commitOffsets(boolean)">commitOffsets</a></strong>(boolean retryOnFailure)</code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#commitOffsets(java.util.Map,%20boolean)">commitOffsets</a></strong>(java.util.Map<kafka.common.TopicAndPartition,kafka.common.OffsetAndMetadata> offsetsToCommit, - boolean retryOnFailure)</code> -<div class="block">Commit offsets using the provided offsets map</div> -</td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>>></code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#createMessageStreams(java.util.Map)">createMessageStreams</a></strong>(java.util.Map<java.lang.String,java.lang.Integer> topicCountMap)</code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code><K,V> java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<K,V>>></code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#createMessageStreams(java.util.Map,%20kafka.serializer.Decoder,%20kafka.serializer.Decoder)">createMessageStreams</a></strong>(java.util.Map<java.lang.String,java.lang.Integer> topicCountMap, - kafka.serializer.Decoder<K> keyDecoder, - kafka.serializer.Decoder<V> valueDecoder)</code> -<div class="block">Create a list of MessageStreams of type T for each topic.</div> -</td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>></code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#createMessageStreamsByFilter(kafka.consumer.TopicFilter)">createMessageStreamsByFilter</a></strong>(kafka.consumer.TopicFilter topicFilter)</code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>></code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#createMessageStreamsByFilter(kafka.consumer.TopicFilter,%20int)">createMessageStreamsByFilter</a></strong>(kafka.consumer.TopicFilter topicFilter, - int numStreams)</code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code><K,V> java.util.List<kafka.consumer.KafkaStream<K,V>></code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#createMessageStreamsByFilter(kafka.consumer.TopicFilter,%20int,%20kafka.serializer.Decoder,%20kafka.serializer.Decoder)">createMessageStreamsByFilter</a></strong>(kafka.consumer.TopicFilter topicFilter, - int numStreams, - kafka.serializer.Decoder<K> keyDecoder, - kafka.serializer.Decoder<V> valueDecoder)</code> -<div class="block">Create a list of MessageAndTopicStreams containing messages of type T.</div> -</td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#setConsumerRebalanceListener(kafka.javaapi.consumer.ConsumerRebalanceListener)">setConsumerRebalanceListener</a></strong>(<a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer">ConsumerRebalanceListener</a> listener)</code> -<div class="block">Wire in a consumer rebalance listener to be executed when consumer rebalance occurs.</div> -</td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html#shutdown()">shutdown</a></strong>()</code> -<div class="block">Shut down the connector</div> -</td> -</tr> -</table> -</li> -</ul> -</li> -</ul> -</div> -<div class="details"> -<ul class="blockList"> -<li class="blockList"> -<!-- ============ METHOD DETAIL ========== --> -<ul class="blockList"> -<li class="blockList"><a name="method_detail"> -<!-- --> -</a> -<h3>Method Detail</h3> -<a name="createMessageStreams(java.util.Map, kafka.serializer.Decoder, kafka.serializer.Decoder)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>createMessageStreams</h4> -<pre><K,V> java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<K,V>>> createMessageStreams(java.util.Map<java.lang.String,java.lang.Integer> topicCountMap, - kafka.serializer.Decoder<K> keyDecoder, - kafka.serializer.Decoder<V> valueDecoder)</pre> -<div class="block">Create a list of MessageStreams of type T for each topic.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>topicCountMap</code> - a map of (topic, #streams) pair</dd><dd><code>keyDecoder</code> - a decoder that decodes the message key</dd><dd><code>valueDecoder</code> - a decoder that decodes the message itself</dd> -<dt><span class="strong">Returns:</span></dt><dd>a map of (topic, list of KafkaStream) pairs. - The number of items in the list is #streams. Each stream supports - an iterator over message/metadata pairs.</dd></dl> -</li> -</ul> -<a name="createMessageStreams(java.util.Map)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>createMessageStreams</h4> -<pre>java.util.Map<java.lang.String,java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>>> createMessageStreams(java.util.Map<java.lang.String,java.lang.Integer> topicCountMap)</pre> -</li> -</ul> -<a name="createMessageStreamsByFilter(kafka.consumer.TopicFilter, int, kafka.serializer.Decoder, kafka.serializer.Decoder)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>createMessageStreamsByFilter</h4> -<pre><K,V> java.util.List<kafka.consumer.KafkaStream<K,V>> createMessageStreamsByFilter(kafka.consumer.TopicFilter topicFilter, - int numStreams, - kafka.serializer.Decoder<K> keyDecoder, - kafka.serializer.Decoder<V> valueDecoder)</pre> -<div class="block">Create a list of MessageAndTopicStreams containing messages of type T.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>topicFilter</code> - a TopicFilter that specifies which topics to - subscribe to (encapsulates a whitelist or a blacklist).</dd><dd><code>numStreams</code> - the number of message streams to return.</dd><dd><code>keyDecoder</code> - a decoder that decodes the message key</dd><dd><code>valueDecoder</code> - a decoder that decodes the message itself</dd> -<dt><span class="strong">Returns:</span></dt><dd>a list of KafkaStream. Each stream supports an - iterator over its MessageAndMetadata elements.</dd></dl> -</li> -</ul> -<a name="createMessageStreamsByFilter(kafka.consumer.TopicFilter, int)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>createMessageStreamsByFilter</h4> -<pre>java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>> createMessageStreamsByFilter(kafka.consumer.TopicFilter topicFilter, - int numStreams)</pre> -</li> -</ul> -<a name="createMessageStreamsByFilter(kafka.consumer.TopicFilter)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>createMessageStreamsByFilter</h4> -<pre>java.util.List<kafka.consumer.KafkaStream<byte[],byte[]>> createMessageStreamsByFilter(kafka.consumer.TopicFilter topicFilter)</pre> -</li> -</ul> -<a name="commitOffsets()"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>commitOffsets</h4> -<pre>void commitOffsets()</pre> -<div class="block">Commit the offsets of all broker partitions connected by this connector.</div> -</li> -</ul> -<a name="commitOffsets(boolean)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>commitOffsets</h4> -<pre>void commitOffsets(boolean retryOnFailure)</pre> -</li> -</ul> -<a name="commitOffsets(java.util.Map, boolean)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>commitOffsets</h4> -<pre>void commitOffsets(java.util.Map<kafka.common.TopicAndPartition,kafka.common.OffsetAndMetadata> offsetsToCommit, - boolean retryOnFailure)</pre> -<div class="block">Commit offsets using the provided offsets map</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>offsetsToCommit</code> - a map containing the offset to commit for each partition.</dd><dd><code>retryOnFailure</code> - enable retries on the offset commit if it fails.</dd></dl> -</li> -</ul> -<a name="setConsumerRebalanceListener(kafka.javaapi.consumer.ConsumerRebalanceListener)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>setConsumerRebalanceListener</h4> -<pre>void setConsumerRebalanceListener(<a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer">ConsumerRebalanceListener</a> listener)</pre> -<div class="block">Wire in a consumer rebalance listener to be executed when consumer rebalance occurs.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>listener</code> - The consumer rebalance listener to wire in</dd></dl> -</li> -</ul> -<a name="shutdown()"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>shutdown</h4> -<pre>void shutdown()</pre> -<div class="block">Shut down the connector</div> -</li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -</div> -<!-- ========= END OF CLASS DATA ========= --> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar_bottom"> -<!-- --> -</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev Class</li> -<li><a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer"><span class="strong">Next Class</span></a></li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/ConsumerConnector.html" target="_top">Frames</a></li> -<li><a href="ConsumerConnector.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_detail">Method</a></li> -</ul> -</div> -<a name="skip-navbar_bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/kafka/javaapi/consumer/ConsumerRebalanceListener.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/kafka/javaapi/consumer/ConsumerRebalanceListener.html b/0100/javadoc/kafka/javaapi/consumer/ConsumerRebalanceListener.html deleted file mode 100644 index 9bd27e6..0000000 --- a/0100/javadoc/kafka/javaapi/consumer/ConsumerRebalanceListener.html +++ /dev/null @@ -1,236 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>ConsumerRebalanceListener (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> -<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style"> -</head> -<body> -<script type="text/javascript"><!-- - if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ConsumerRebalanceListener (core 0.10.0.0 API)"; - } -//--> -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar_top"> -<!-- --> -</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html" title="interface in kafka.javaapi.consumer"><span class="strong">Prev Class</span></a></li> -<li>Next Class</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/ConsumerRebalanceListener.html" target="_top">Frames</a></li> -<li><a href="ConsumerRebalanceListener.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_detail">Method</a></li> -</ul> -</div> -<a name="skip-navbar_top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<!-- ======== START OF CLASS DATA ======== --> -<div class="header"> -<div class="subTitle">kafka.javaapi.consumer</div> -<h2 title="Interface ConsumerRebalanceListener" class="title">Interface ConsumerRebalanceListener</h2> -</div> -<div class="contentContainer"> -<div class="description"> -<ul class="blockList"> -<li class="blockList"> -<hr> -<br> -<pre>public interface <span class="strong">ConsumerRebalanceListener</span></pre> -<div class="block">This listener is used for execution of tasks defined by user when a consumer rebalance - occurs in <code>ZookeeperConsumerConnector</code></div> -</li> -</ul> -</div> -<div class="summary"> -<ul class="blockList"> -<li class="blockList"> -<!-- ========== METHOD SUMMARY =========== --> -<ul class="blockList"> -<li class="blockList"><a name="method_summary"> -<!-- --> -</a> -<h3>Method Summary</h3> -<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span>Methods</span><span class="tabEnd"> </span></caption> -<tr> -<th class="colFirst" scope="col">Modifier and Type</th> -<th class="colLast" scope="col">Method and Description</th> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html#beforeReleasingPartitions(java.util.Map)">beforeReleasingPartitions</a></strong>(java.util.Map<java.lang.String,java.util.Set<java.lang.Integer>> partitionOwnership)</code> -<div class="block">This method is called after all the fetcher threads are stopped but before the - ownership of partitions are released.</div> -</td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html#beforeStartingFetchers(java.lang.String,%20java.util.Map)">beforeStartingFetchers</a></strong>(java.lang.String consumerId, - java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,kafka.consumer.ConsumerThreadId>> globalPartitionAssignment)</code> -<div class="block">This method is called after the new partition assignment is finished but before fetcher - threads start.</div> -</td> -</tr> -</table> -</li> -</ul> -</li> -</ul> -</div> -<div class="details"> -<ul class="blockList"> -<li class="blockList"> -<!-- ============ METHOD DETAIL ========== --> -<ul class="blockList"> -<li class="blockList"><a name="method_detail"> -<!-- --> -</a> -<h3>Method Detail</h3> -<a name="beforeReleasingPartitions(java.util.Map)"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>beforeReleasingPartitions</h4> -<pre>void beforeReleasingPartitions(java.util.Map<java.lang.String,java.util.Set<java.lang.Integer>> partitionOwnership)</pre> -<div class="block">This method is called after all the fetcher threads are stopped but before the - ownership of partitions are released. Depending on whether auto offset commit is - enabled or not, offsets may or may not have been committed. - This listener is initially added to prevent duplicate messages on consumer rebalance - in mirror maker, where offset auto commit is disabled to prevent data loss. It could - also be used in more general cases.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>partitionOwnership</code> - The partition this consumer currently owns.</dd></dl> -</li> -</ul> -<a name="beforeStartingFetchers(java.lang.String, java.util.Map)"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>beforeStartingFetchers</h4> -<pre>void beforeStartingFetchers(java.lang.String consumerId, - java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,kafka.consumer.ConsumerThreadId>> globalPartitionAssignment)</pre> -<div class="block">This method is called after the new partition assignment is finished but before fetcher - threads start. A map of new global partition assignment is passed in as parameter.</div> -<dl><dt><span class="strong">Parameters:</span></dt><dd><code>consumerId</code> - The consumer Id string of the consumer invoking this callback.</dd><dd><code>globalPartitionAssignment</code> - A Map[topic, Map[Partition, ConsumerThreadId]]. It is the global partition - assignment of this consumer group.</dd></dl> -</li> -</ul> -</li> -</ul> -</li> -</ul> -</div> -</div> -<!-- ========= END OF CLASS DATA ========= --> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar_bottom"> -<!-- --> -</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li class="navBarCell1Rev">Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html" title="interface in kafka.javaapi.consumer"><span class="strong">Prev Class</span></a></li> -<li>Next Class</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/ConsumerRebalanceListener.html" target="_top">Frames</a></li> -<li><a href="ConsumerRebalanceListener.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<div> -<ul class="subNavList"> -<li>Summary: </li> -<li>Nested | </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_summary">Method</a></li> -</ul> -<ul class="subNavList"> -<li>Detail: </li> -<li>Field | </li> -<li>Constr | </li> -<li><a href="#method_detail">Method</a></li> -</ul> -</div> -<a name="skip-navbar_bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/kafka/javaapi/consumer/package-frame.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/kafka/javaapi/consumer/package-frame.html b/0100/javadoc/kafka/javaapi/consumer/package-frame.html deleted file mode 100644 index 2bde005..0000000 --- a/0100/javadoc/kafka/javaapi/consumer/package-frame.html +++ /dev/null @@ -1,20 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>kafka.javaapi.consumer (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> -<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style"> -</head> -<body> -<h1 class="bar"><a href="../../../kafka/javaapi/consumer/package-summary.html" target="classFrame">kafka.javaapi.consumer</a></h1> -<div class="indexContainer"> -<h2 title="Interfaces">Interfaces</h2> -<ul title="Interfaces"> -<li><a href="ConsumerConnector.html" title="interface in kafka.javaapi.consumer" target="classFrame"><i>ConsumerConnector</i></a></li> -<li><a href="ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer" target="classFrame"><i>ConsumerRebalanceListener</i></a></li> -</ul> -</div> -</body> -</html> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/kafka/javaapi/consumer/package-summary.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/kafka/javaapi/consumer/package-summary.html b/0100/javadoc/kafka/javaapi/consumer/package-summary.html deleted file mode 100644 index 6f665b5..0000000 --- a/0100/javadoc/kafka/javaapi/consumer/package-summary.html +++ /dev/null @@ -1,136 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>kafka.javaapi.consumer (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> -<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="kafka.javaapi.consumer (core 0.10.0.0 API)"; - } -//--> -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar_top"> -<!-- --> -</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li>Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev Package</li> -<li>Next Package</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/package-summary.html" target="_top">Frames</a></li> -<li><a href="package-summary.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<a name="skip-navbar_top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<div class="header"> -<h1 title="Package" class="title">Package kafka.javaapi.consumer</h1> -</div> -<div class="contentContainer"> -<ul class="blockList"> -<li class="blockList"> -<table class="packageSummary" border="0" cellpadding="3" cellspacing="0" summary="Interface Summary table, listing interfaces, and an explanation"> -<caption><span>Interface Summary</span><span class="tabEnd"> </span></caption> -<tr> -<th class="colFirst" scope="col">Interface</th> -<th class="colLast" scope="col">Description</th> -</tr> -<tbody> -<tr class="altColor"> -<td class="colFirst"><a href="../../../kafka/javaapi/consumer/ConsumerConnector.html" title="interface in kafka.javaapi.consumer">ConsumerConnector</a></td> -<td class="colLast"> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer">ConsumerRebalanceListener</a></td> -<td class="colLast"> -<div class="block">This listener is used for execution of tasks defined by user when a consumer rebalance - occurs in <code>ZookeeperConsumerConnector</code></div> -</td> -</tr> -</tbody> -</table> -</li> -</ul> -</div> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar_bottom"> -<!-- --> -</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li>Class</li> -<li><a href="package-tree.html">Tree</a></li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev Package</li> -<li>Next Package</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/package-summary.html" target="_top">Frames</a></li> -<li><a href="package-summary.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<a name="skip-navbar_bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/kafka/javaapi/consumer/package-tree.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/kafka/javaapi/consumer/package-tree.html b/0100/javadoc/kafka/javaapi/consumer/package-tree.html deleted file mode 100644 index 36f919a..0000000 --- a/0100/javadoc/kafka/javaapi/consumer/package-tree.html +++ /dev/null @@ -1,117 +0,0 @@ -<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> -<!-- NewPage --> -<html lang="en"> -<head> -<!-- Generated by javadoc (version 1.7.0_79) on Fri Apr 29 16:30:04 PDT 2016 --> -<title>kafka.javaapi.consumer Class Hierarchy (core 0.10.0.0 API)</title> -<meta name="date" content="2016-04-29"> -<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="kafka.javaapi.consumer Class Hierarchy (core 0.10.0.0 API)"; - } -//--> -</script> -<noscript> -<div>JavaScript is disabled on your browser.</div> -</noscript> -<!-- ========= START OF TOP NAVBAR ======= --> -<div class="topNav"><a name="navbar_top"> -<!-- --> -</a><a href="#skip-navbar_top" title="Skip navigation links"></a><a name="navbar_top_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li>Class</li> -<li class="navBarCell1Rev">Tree</li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev</li> -<li>Next</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/package-tree.html" target="_top">Frames</a></li> -<li><a href="package-tree.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_top"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_top"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<a name="skip-navbar_top"> -<!-- --> -</a></div> -<!-- ========= END OF TOP NAVBAR ========= --> -<div class="header"> -<h1 class="title">Hierarchy For Package kafka.javaapi.consumer</h1> -</div> -<div class="contentContainer"> -<h2 title="Interface Hierarchy">Interface Hierarchy</h2> -<ul> -<li type="circle">kafka.javaapi.consumer.<a href="../../../kafka/javaapi/consumer/ConsumerConnector.html" title="interface in kafka.javaapi.consumer"><span class="strong">ConsumerConnector</span></a></li> -<li type="circle">kafka.javaapi.consumer.<a href="../../../kafka/javaapi/consumer/ConsumerRebalanceListener.html" title="interface in kafka.javaapi.consumer"><span class="strong">ConsumerRebalanceListener</span></a></li> -</ul> -</div> -<!-- ======= START OF BOTTOM NAVBAR ====== --> -<div class="bottomNav"><a name="navbar_bottom"> -<!-- --> -</a><a href="#skip-navbar_bottom" title="Skip navigation links"></a><a name="navbar_bottom_firstrow"> -<!-- --> -</a> -<ul class="navList" title="Navigation"> -<li><a href="../../../kafka/javaapi/consumer/package-summary.html">Package</a></li> -<li>Class</li> -<li class="navBarCell1Rev">Tree</li> -<li><a href="../../../deprecated-list.html">Deprecated</a></li> -<li><a href="../../../index-all.html">Index</a></li> -<li><a href="../../../help-doc.html">Help</a></li> -</ul> -</div> -<div class="subNav"> -<ul class="navList"> -<li>Prev</li> -<li>Next</li> -</ul> -<ul class="navList"> -<li><a href="../../../index.html?kafka/javaapi/consumer/package-tree.html" target="_top">Frames</a></li> -<li><a href="package-tree.html" target="_top">No Frames</a></li> -</ul> -<ul class="navList" id="allclasses_navbar_bottom"> -<li><a href="../../../allclasses-noframe.html">All Classes</a></li> -</ul> -<div> -<script type="text/javascript"><!-- - allClassesLink = document.getElementById("allclasses_navbar_bottom"); - if(window==top) { - allClassesLink.style.display = "block"; - } - else { - allClassesLink.style.display = "none"; - } - //--> -</script> -</div> -<a name="skip-navbar_bottom"> -<!-- --> -</a></div> -<!-- ======== END OF BOTTOM NAVBAR ======= --> -</body> -</html> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html b/0100/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html index 027689e..4ce0769 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/CommitFailedException.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>CommitFailedException (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:03 BST 2016 --> +<title>CommitFailedException (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="CommitFailedException (clients 0.10.0.0 API)"; + parent.document.title="CommitFailedException (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> @@ -115,7 +115,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> @@ -144,7 +144,7 @@ extends <a href="../../../../../org/apache/kafka/common/KafkaException.html" tit <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/CommitFailedException.html#CommitFailedException(java.lang.String)">CommitFailedException</a></strong>(java.lang.String message)</code> </td> +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/CommitFailedException.html#CommitFailedException(java.lang.String)">CommitFailedException</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> message)</code> </td> </tr> </table> </li> @@ -159,15 +159,15 @@ extends <a href="../../../../../org/apache/kafka/common/KafkaException.html" tit <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> @@ -189,7 +189,7 @@ extends <a href="../../../../../org/apache/kafka/common/KafkaException.html" tit <ul class="blockListLast"> <li class="blockList"> <h4>CommitFailedException</h4> -<pre>public CommitFailedException(java.lang.String message)</pre> +<pre>public CommitFailedException(<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> message)</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/clients/consumer/Consumer.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/clients/consumer/Consumer.html b/0100/javadoc/org/apache/kafka/clients/consumer/Consumer.html index 89c492e..bec41a4 100644 --- a/0100/javadoc/org/apache/kafka/clients/consumer/Consumer.html +++ b/0100/javadoc/org/apache/kafka/clients/consumer/Consumer.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>Consumer (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:03 BST 2016 --> +<title>Consumer (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="Consumer (clients 0.10.0.0 API)"; + parent.document.title="Consumer (kafka 0.10.0.0 API)"; } //--> </script> @@ -87,7 +87,7 @@ <li class="blockList"> <dl> <dt>All Superinterfaces:</dt> -<dd>java.lang.AutoCloseable, java.io.Closeable</dd> +<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html?is-external=true"; title="class or interface in java.lang">AutoCloseable</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true"; title="class or interface in java.io">Closeable</a></dd> </dl> <dl> <dt>All Known Implementing Classes:</dt> @@ -96,7 +96,7 @@ <hr> <br> <pre>public interface <span class="strong">Consumer<K,V></span> -extends java.io.Closeable</pre> +extends <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.html?is-external=true"; title="class or interface in java.io">Closeable</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer"><code>KafkaConsumer</code></a>, <a href="../../../../../org/apache/kafka/clients/consumer/MockConsumer.html" title="class in org.apache.kafka.clients.consumer"><code>MockConsumer</code></a></dd></dl> </li> @@ -119,10 +119,10 @@ extends java.io.Closeable</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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="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/Consumer.html#assignment()">assignment</a></strong>()</code> </td> </tr> <tr class="altColor"> @@ -135,7 +135,7 @@ extends java.io.Closeable</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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"> @@ -148,30 +148,30 @@ extends java.io.Closeable</pre> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.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/Consumer.html#paused()">paused</a></strong>()</code> </td> </tr> <tr class="altColor"> @@ -184,7 +184,7 @@ extends java.io.Closeable</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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="rowColor"> <td class="colFirst"><code>void</code></td> @@ -193,28 +193,28 @@ extends java.io.Closeable</pre> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/clients/consumer/Consumer.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/Consumer.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/Consumer.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/Consumer.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> callback)</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/Consumer.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/Consumer.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> callback)</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/Consumer.html#subscription()">subscription</a></strong>()</code> </td> </tr> <tr class="altColor"> @@ -246,7 +246,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>assignment</h4> -<pre>java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> assignment()</pre> +<pre><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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assignment()"><code>KafkaConsumer.assignment()</code></a></dd></dl> </li> </ul> @@ -256,7 +256,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>subscription</h4> -<pre>java.util.Set<java.lang.String> subscription()</pre> +<pre><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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscription()"><code>KafkaConsumer.subscription()</code></a></dd></dl> </li> </ul> @@ -266,7 +266,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>void subscribe(java.util.Collection<java.lang.String> topics)</pre> +<pre>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)"><code>KafkaConsumer.subscribe(Collection)</code></a></dd></dl> </li> </ul> @@ -276,7 +276,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>void subscribe(java.util.Collection<java.lang.String> topics, +<pre>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> callback)</pre> <dl><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>KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener)</code></a></dd></dl> </li> @@ -287,7 +287,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>assign</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)"><code>KafkaConsumer.assign(Collection)</code></a></dd></dl> </li> </ul> @@ -297,7 +297,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>subscribe</h4> -<pre>void subscribe(java.util.regex.Pattern pattern, +<pre>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> callback)</pre> <dl><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>KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener)</code></a></dd></dl> </li> @@ -338,7 +338,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>commitSync</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitSync(java.util.Map)"><code>KafkaConsumer.commitSync(Map)</code></a></dd></dl> </li> </ul> @@ -368,7 +368,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>commitAsync</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#commitAsync(java.util.Map,%20org.apache.kafka.clients.consumer.OffsetCommitCallback)"><code>KafkaConsumer.commitAsync(Map, OffsetCommitCallback)</code></a></dd></dl> </li> @@ -390,7 +390,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>seekToBeginning</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToBeginning(java.util.Collection)"><code>KafkaConsumer.seekToBeginning(Collection)</code></a></dd></dl> </li> </ul> @@ -400,7 +400,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>seekToEnd</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToEnd(java.util.Collection)"><code>KafkaConsumer.seekToEnd(Collection)</code></a></dd></dl> </li> </ul> @@ -430,7 +430,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>metrics</h4> -<pre>java.util.Map<<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/MetricName.html" title="class in org.apache.kafka.common">MetricName</a>,? extends <a href="../../../../../org/apache/kafka/common/Metric.html" title="interface in org.apache.kafka.common">Metric</a>> metrics()</pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#metrics()"><code>KafkaConsumer.metrics()</code></a></dd></dl> </li> </ul> @@ -440,7 +440,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>partitionsFor</h4> -<pre>java.util.List<<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(java.lang.String topic)</pre> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a>> partitionsFor(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic)</pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)"><code>KafkaConsumer.partitionsFor(String)</code></a></dd></dl> </li> </ul> @@ -450,7 +450,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>listTopics</h4> -<pre>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><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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics()"><code>KafkaConsumer.listTopics()</code></a></dd></dl> </li> </ul> @@ -460,7 +460,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>paused</h4> -<pre>java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> paused()</pre> +<pre><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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#paused()"><code>KafkaConsumer.paused()</code></a></dd></dl> </li> </ul> @@ -470,7 +470,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>pause</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)"><code>KafkaConsumer.pause(Collection)</code></a></dd></dl> </li> </ul> @@ -480,7 +480,7 @@ extends java.io.Closeable</pre> <ul class="blockList"> <li class="blockList"> <h4>resume</h4> -<pre>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>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><span class="strong">See Also:</span></dt><dd><a href="../../../../../org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection)"><code>KafkaConsumer.resume(Collection)</code></a></dd></dl> </li> </ul> @@ -493,9 +493,9 @@ extends java.io.Closeable</pre> <pre>void close()</pre> <dl> <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>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><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> </li> </ul>
