edgent-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kathyssaund...@apache.org
Subject [32/62] [abbrv] [partial] incubator-quarks-website git commit: Add javadoc init for "lastest", "0.4"
Date Fri, 03 Jun 2016 18:48:34 GMT
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html b/site/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
new file mode 100644
index 0000000..81c6e64
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
@@ -0,0 +1,425 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:45 UTC 2016 -->
+<title>KafkaConsumer (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="KafkaConsumer (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+var methods = {"i0":10,"i1":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/KafkaConsumer.html">Use</a></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&nbsp;Class</li>
+<li><a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/KafkaConsumer.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
+<li><a href="#nested.class.summary">Nested</a>&nbsp;|&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail:&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</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">quarks.connectors.kafka</div>
+<h2 title="Class KafkaConsumer" class="title">Class KafkaConsumer</h2>
+</div>
+<div class="contentContainer">
+<ul class="inheritance">
+<li>java.lang.Object</li>
+<li>
+<ul class="inheritance">
+<li>quarks.connectors.kafka.KafkaConsumer</li>
+</ul>
+</li>
+</ul>
+<div class="description">
+<ul class="blockList">
+<li class="blockList">
+<hr>
+<br>
+<pre>public class <span class="typeNameLabel">KafkaConsumer</span>
+extends java.lang.Object</pre>
+<div class="block"><code>KafkaConsumer</code> is a connector for creating a stream of tuples
+ by subscribing to Apache Kafka messaging system topics.
+ <p>
+ The connector uses and includes components from the Kafka 0.8.2.2 release.
+ It has been successfully tested against a kafka_2.11-0.9.0.0 server as well.
+ For more information about Kafka see
+ <a href="http://kafka.apache.org">http://kafka.apache.org</a>
+ <p>
+ Sample use:
+ <pre><code>
+ String zookeeperConnect = "localhost:2181";
+ String groupId = "myGroupId";
+ String topic = "mySensorReadingsTopic";
+ 
+ Map&lt;String,Object&gt; config = new HashMap&lt;&gt;();
+ config.put("zookeeper.connect", zookeeperConnect);
+ config.put("groupId", groupId);
+ 
+ Topology t = ...
+ KafkaConsumer kafka = new KafkaConsumer(t, () -&gt; config);
+              
+ // subscribe to a topic where sensor readings are published as JSON,
+ // creating a stream of JSON tuples  
+ TStream&lt;String&gt; sensorReadingsJson =
+              kafka.subscribe(rec -&gt; rec.value(), topic);
+ 
+ // print the received messages
+ sensorReadingsJson.print();
+ </code></pre></div>
+</li>
+</ul>
+</div>
+<div class="summary">
+<ul class="blockList">
+<li class="blockList">
+<!-- ======== NESTED CLASS SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="nested.class.summary">
+<!--   -->
+</a>
+<h3>Nested Class Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Nested Class Summary table, listing nested classes, and an explanation">
+<caption><span>Nested Classes</span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Class and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>static interface&nbsp;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a></span></code>
+<div class="block">A Kafka record with byte[] typed key and value members</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>static interface&nbsp;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a>&lt;<a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="type parameter in KafkaConsumer.ConsumerRecord">K</a>,<a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="type parameter in KafkaConsumer.ConsumerRecord">V</a>&gt;</span></code>
+<div class="block">A received Kafka record</div>
+</td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><code>static interface&nbsp;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a></span></code>
+<div class="block">A Kafka record with String typed key and value members</div>
+</td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ======== CONSTRUCTOR SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.summary">
+<!--   -->
+</a>
+<h3>Constructor Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
+<caption><span>Constructors</span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colOne" scope="col">Constructor and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.html#KafkaConsumer-quarks.topology.Topology-quarks.function.Supplier-">KafkaConsumer</a></span>(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a>&nbsp;t,
+             <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a>&lt;java.util.Map&lt;java.lang.String,java.lang.Object&gt;&gt;&nbsp;config)</code>
+<div class="block">Create a consumer connector for subscribing to Kafka topics
+ and creating tuples from the received messages.</div>
+</td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ========== METHOD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.summary">
+<!--   -->
+</a>
+<h3>Method Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd">&nbsp;</span></span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tr id="i0" class="altColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.html#subscribe-quarks.function.Function-java.lang.String...-">subscribe</a></span>(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+         java.lang.String...&nbsp;topics)</code>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.</div>
+</td>
+</tr>
+<tr id="i1" class="rowColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaConsumer.html#subscribeBytes-quarks.function.Function-java.lang.String...-">subscribeBytes</a></span>(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+              java.lang.String...&nbsp;topics)</code>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.</div>
+</td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
+<!--   -->
+</a>
+<h3>Methods inherited from class&nbsp;java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<div class="details">
+<ul class="blockList">
+<li class="blockList">
+<!-- ========= CONSTRUCTOR DETAIL ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.detail">
+<!--   -->
+</a>
+<h3>Constructor Detail</h3>
+<a name="KafkaConsumer-quarks.topology.Topology-quarks.function.Supplier-">
+<!--   -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>KafkaConsumer</h4>
+<pre>public&nbsp;KafkaConsumer(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a>&nbsp;t,
+                     <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a>&lt;java.util.Map&lt;java.lang.String,java.lang.Object&gt;&gt;&nbsp;config)</pre>
+<div class="block">Create a consumer connector for subscribing to Kafka topics
+ and creating tuples from the received messages.
+ <p>
+ See the Apache Kafka documentation for "Old Consumer Configs"
+ configuration properties at <a href="http://kafka.apache.org">http://kafka.apache.org</a>.
+ Configuration property values are strings.
+ <p>
+ The Kafka "Old Consumer" configs are used.  Minimal configuration
+ typically includes:
+ <p>
+ <ul>
+ <li><code>zookeeper.connect</code></li>
+ <li><code>group.id</code></li>
+ </ul></div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>config</code> - KafkaConsumer configuration information.</dd>
+</dl>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ============ METHOD DETAIL ========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.detail">
+<!--   -->
+</a>
+<h3>Method Detail</h3>
+<a name="subscribeBytes-quarks.function.Function-java.lang.String...-">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>subscribeBytes</h4>
+<pre>public&nbsp;&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;subscribeBytes(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+                                     java.lang.String...&nbsp;topics)</pre>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.
+ <p>
+ Kafka's consumer group management functionality is used to automatically
+ allocate, and dynamically reallocate, the topic's partitions to this connector. 
+ <p>
+ In line with Kafka's evolving new KafkaConsumer interface, subscribing
+ to a topic advertises a single thread to the server for partition allocation.
+ <p>
+ Currently, subscribe*() can only be called once for a KafkaConsumer
+ instance.  This restriction will be removed once we migrate to Kafka 0.9.0.0.</div>
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>T</code> - tuple type</dd>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>toTupleFn</code> - A function that yields a tuple from a <code>ByteConsumerRecord</code></dd>
+<dd><code>topics</code> - the topics to subscribe to.</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>stream of tuples</dd>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code>java.lang.IllegalArgumentException</code> - for a duplicate or conflicting subscription</dd>
+</dl>
+</li>
+</ul>
+<a name="subscribe-quarks.function.Function-java.lang.String...-">
+<!--   -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>subscribe</h4>
+<pre>public&nbsp;&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;subscribe(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+                                java.lang.String...&nbsp;topics)</pre>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.
+ <p>
+ Kafka's consumer group management functionality is used to automatically
+ allocate, and dynamically reallocate, the topic's partitions to this connector. 
+ <p>
+ In line with Kafka's evolving new KafkaConsumer interface, subscribing
+ to a topic advertises a single thread to the server for partition allocation.
+ <p>
+ Currently, subscribe*() can only be called once for a KafkaConsumer
+ instance.  This restriction will be removed once we migrate to Kafka 0.9.0.0.</div>
+<dl>
+<dt><span class="paramLabel">Type Parameters:</span></dt>
+<dd><code>T</code> - tuple type</dd>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>toTupleFn</code> - A function that yields a tuple from a <code>StringConsumerRecord</code></dd>
+<dd><code>topics</code> - the topics to subscribe to.</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd>stream of tuples</dd>
+<dt><span class="throwsLabel">Throws:</span></dt>
+<dd><code>java.lang.IllegalArgumentException</code> - for a duplicate or conflicting subscription</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>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/KafkaConsumer.html">Use</a></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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev&nbsp;Class</li>
+<li><a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/KafkaConsumer.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
+<li><a href="#nested.class.summary">Nested</a>&nbsp;|&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail:&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.detail">Method</a></li>
+</ul>
+</div>
+<a name="skip.navbar.bottom">
+<!--   -->
+</a></div>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html b/site/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
new file mode 100644
index 0000000..c58c0a6
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
@@ -0,0 +1,436 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:45 UTC 2016 -->
+<title>KafkaProducer (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="KafkaProducer (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+var methods = {"i0":10,"i1":10,"i2":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/KafkaProducer.html">Use</a></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="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
+<li>Next&nbsp;Class</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/KafkaProducer.html" target="_top">Frames</a></li>
+<li><a href="KafkaProducer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
+<li>Nested&nbsp;|&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail:&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</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">quarks.connectors.kafka</div>
+<h2 title="Class KafkaProducer" class="title">Class KafkaProducer</h2>
+</div>
+<div class="contentContainer">
+<ul class="inheritance">
+<li>java.lang.Object</li>
+<li>
+<ul class="inheritance">
+<li>quarks.connectors.kafka.KafkaProducer</li>
+</ul>
+</li>
+</ul>
+<div class="description">
+<ul class="blockList">
+<li class="blockList">
+<hr>
+<br>
+<pre>public class <span class="typeNameLabel">KafkaProducer</span>
+extends java.lang.Object</pre>
+<div class="block"><code>KafkaProducer</code> is a connector for publishing a stream of tuples
+ to Apache Kafka messaging system topics.
+ <p>
+ The connector uses and includes components from the Kafka 0.8.2.2 release.
+ It has been successfully tested against a kafka_2.11-0.9.0.0 server as well.
+ For more information about Kafka see
+ <a href="http://kafka.apache.org">http://kafka.apache.org</a>
+ <p>
+ Sample use:
+ <pre><code>
+ String bootstrapServers = "localhost:9092";
+ String topic = "mySensorReadingsTopic";
+ 
+ Map&lt;String,Object&gt; config = new HashMap&lt;&gt;();
+ config.put("bootstrap.servers", bootstrapServers);
+ 
+ Topology t = ...
+ KafkaProducer kafka = new KafkaProducer(t, () -&gt; config);
+ 
+ TStream&lt;JsonObject&gt; sensorReadings = t.poll(
+              () -&gt; getSensorReading(), 5, TimeUnit.SECONDS);
+              
+ // publish as sensor readings as JSON
+ kafka.publish(sensonReadings, tuple -&gt; tuple.toString(), topic);
+ </code></pre></div>
+</li>
+</ul>
+</div>
+<div class="summary">
+<ul class="blockList">
+<li class="blockList">
+<!-- ======== CONSTRUCTOR SUMMARY ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.summary">
+<!--   -->
+</a>
+<h3>Constructor Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation">
+<caption><span>Constructors</span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colOne" scope="col">Constructor and Description</th>
+</tr>
+<tr class="altColor">
+<td class="colOne"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaProducer.html#KafkaProducer-quarks.topology.Topology-quarks.function.Supplier-">KafkaProducer</a></span>(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a>&nbsp;t,
+             <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a>&lt;java.util.Map&lt;java.lang.String,java.lang.Object&gt;&gt;&nbsp;config)</code>
+<div class="block">Create a producer connector for publishing tuples to Kafka topics.s</div>
+</td>
+</tr>
+</table>
+</li>
+</ul>
+<!-- ========== METHOD SUMMARY =========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.summary">
+<!--   -->
+</a>
+<h3>Method Summary</h3>
+<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd">&nbsp;</span></span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tr id="i0" class="altColor">
+<td class="colFirst"><code><a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;java.lang.String&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaProducer.html#publish-quarks.topology.TStream-java.lang.String-">publish</a></span>(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;java.lang.String&gt;&nbsp;stream,
+       java.lang.String&nbsp;topic)</code>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified partitions of the specified topics.</div>
+</td>
+</tr>
+<tr id="i1" class="rowColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaProducer.html#publish-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">publish</a></span>(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;stream,
+       <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;keyFn,
+       <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;valueFn,
+       <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;topicFn,
+       <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.Integer&gt;&nbsp;partitionFn)</code>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified partitions of the specified topics.</div>
+</td>
+</tr>
+<tr id="i2" class="altColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../quarks/connectors/kafka/KafkaProducer.html#publishBytes-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">publishBytes</a></span>(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;stream,
+            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,byte[]&gt;&nbsp;keyFn,
+            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,byte[]&gt;&nbsp;valueFn,
+            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;topicFn,
+            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.Integer&gt;&nbsp;partitionFn)</code>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified topic partitions.</div>
+</td>
+</tr>
+</table>
+<ul class="blockList">
+<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
+<!--   -->
+</a>
+<h3>Methods inherited from class&nbsp;java.lang.Object</h3>
+<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<div class="details">
+<ul class="blockList">
+<li class="blockList">
+<!-- ========= CONSTRUCTOR DETAIL ======== -->
+<ul class="blockList">
+<li class="blockList"><a name="constructor.detail">
+<!--   -->
+</a>
+<h3>Constructor Detail</h3>
+<a name="KafkaProducer-quarks.topology.Topology-quarks.function.Supplier-">
+<!--   -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>KafkaProducer</h4>
+<pre>public&nbsp;KafkaProducer(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a>&nbsp;t,
+                     <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a>&lt;java.util.Map&lt;java.lang.String,java.lang.Object&gt;&gt;&nbsp;config)</pre>
+<div class="block">Create a producer connector for publishing tuples to Kafka topics.s
+ <p>
+ See the Apache Kafka documentation for <code>KafkaProducer</code>
+ configuration properties at <a href="http://kafka.apache.org">http://kafka.apache.org</a>.
+ Configuration property values are strings.
+ <p>
+ The Kafka "New Producer configs" are used.  Minimal configuration
+ typically includes:
+ <p>
+ <ul>
+ <li><code>bootstrap.servers</code></li>
+ </ul>
+ <p>
+ The full set of producer configuration items are specified in
+ <code>org.apache.kafka.clients.producer.ProducerConfig</code></div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>config</code> - KafkaProducer configuration information.</dd>
+</dl>
+</li>
+</ul>
+</li>
+</ul>
+<!-- ============ METHOD DETAIL ========== -->
+<ul class="blockList">
+<li class="blockList"><a name="method.detail">
+<!--   -->
+</a>
+<h3>Method Detail</h3>
+<a name="publishBytes-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>publishBytes</h4>
+<pre>public&nbsp;&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;T&gt;&nbsp;publishBytes(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;stream,
+                                 <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,byte[]&gt;&nbsp;keyFn,
+                                 <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,byte[]&gt;&nbsp;valueFn,
+                                 <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;topicFn,
+                                 <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.Integer&gt;&nbsp;partitionFn)</pre>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified topic partitions.
+ <p>
+ If a valid partition number is specified that partition will be used
+ when sending the message.  If no partition is specified but a key is
+ present a partition will be chosen using a hash of the key.
+ If neither key nor partition is present a partition will be assigned
+ in a round-robin fashion.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>stream</code> - the stream to publish</dd>
+<dd><code>keyFn</code> - A function that yields an optional byte[] 
+        Kafka record's key from the tuple.
+        Specify null or return a null value for no key.</dd>
+<dd><code>valueFn</code> - A function that yields the byte[]
+        Kafka record's value from the tuple.</dd>
+<dd><code>topicFn</code> - A function that yields the topic from the tuple.</dd>
+<dd><code>partitionFn</code> - A function that yields the optional topic
+        partition specification from the tuple.
+        Specify null or return a null value for no partition specification.</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd><a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology"><code>TSink</code></a></dd>
+</dl>
+</li>
+</ul>
+<a name="publish-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-">
+<!--   -->
+</a>
+<ul class="blockList">
+<li class="blockList">
+<h4>publish</h4>
+<pre>public&nbsp;&lt;T&gt;&nbsp;<a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;T&gt;&nbsp;publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;&nbsp;stream,
+                            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;keyFn,
+                            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;valueFn,
+                            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.String&gt;&nbsp;topicFn,
+                            <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;T,java.lang.Integer&gt;&nbsp;partitionFn)</pre>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified partitions of the specified topics.
+ <p>
+ This is a convenience method for <code>String</code> typed key/value
+ conversion functions.
+ <p></div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>stream</code> - the stream to publish</dd>
+<dd><code>keyFn</code> - A function that yields an optional String 
+        Kafka record's key from the tuple.
+        Specify null or return a null value for no key.</dd>
+<dd><code>valueFn</code> - A function that yields the String for the
+        Kafka record's value from the tuple.</dd>
+<dd><code>topicFn</code> - A function that yields the topic from the tuple.</dd>
+<dd><code>partitionFn</code> - A function that yields the optional topic
+        partition specification from the tuple.
+        Specify null or return a null value for no partition specification.</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd><a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology"><code>TSink</code></a></dd>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="../../../quarks/connectors/kafka/KafkaProducer.html#publishBytes-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-"><code>publishBytes(TStream, Function, Function, Function, Function)</code></a></dd>
+</dl>
+</li>
+</ul>
+<a name="publish-quarks.topology.TStream-java.lang.String-">
+<!--   -->
+</a>
+<ul class="blockListLast">
+<li class="blockList">
+<h4>publish</h4>
+<pre>public&nbsp;<a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a>&lt;java.lang.String&gt;&nbsp;publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;java.lang.String&gt;&nbsp;stream,
+                                       java.lang.String&nbsp;topic)</pre>
+<div class="block">Publish the stream of tuples as Kafka key/value records
+ to the specified partitions of the specified topics.
+ <p>
+ This is a convenience method for a String stream published
+ as a Kafka record with no key and
+ a value consisting of the String tuple serialized as UTF-8,
+ and publishing round-robin to a fixed topic's partitions.</div>
+<dl>
+<dt><span class="paramLabel">Parameters:</span></dt>
+<dd><code>stream</code> - the stream to publish</dd>
+<dd><code>topic</code> - The topic to publish to</dd>
+<dt><span class="returnLabel">Returns:</span></dt>
+<dd><a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology"><code>TSink</code></a></dd>
+<dt><span class="seeLabel">See Also:</span></dt>
+<dd><a href="../../../quarks/connectors/kafka/KafkaProducer.html#publish-quarks.topology.TStream-quarks.function.Function-quarks.function.Function-quarks.function.Function-quarks.function.Function-"><code>publish(TStream, Function, Function, Function, Function)</code></a></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>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li><a href="package-summary.html">Package</a></li>
+<li class="navBarCell1Rev">Class</li>
+<li><a href="class-use/KafkaProducer.html">Use</a></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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
+<li>Next&nbsp;Class</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/KafkaProducer.html" target="_top">Frames</a></li>
+<li><a href="KafkaProducer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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:&nbsp;</li>
+<li>Nested&nbsp;|&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.summary">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.summary">Method</a></li>
+</ul>
+<ul class="subNavList">
+<li>Detail:&nbsp;</li>
+<li>Field&nbsp;|&nbsp;</li>
+<li><a href="#constructor.detail">Constr</a>&nbsp;|&nbsp;</li>
+<li><a href="#method.detail">Method</a></li>
+</ul>
+</div>
+<a name="skip.navbar.bottom">
+<!--   -->
+</a></div>
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
new file mode 100644
index 0000000..7079108
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
@@ -0,0 +1,172 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
+<title>Uses of Interface quarks.connectors.kafka.KafkaConsumer.ByteConsumerRecord (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.ByteConsumerRecord (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.ByteConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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">
+<h2 title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.ByteConsumerRecord" class="title">Uses of Interface<br>quarks.connectors.kafka.KafkaConsumer.ByteConsumerRecord</h2>
+</div>
+<div class="classUseContainer">
+<ul class="blockList">
+<li class="blockList">
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing packages, and an explanation">
+<caption><span>Packages that use <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Package</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="#quarks.connectors.kafka">quarks.connectors.kafka</a></td>
+<td class="colLast">
+<div class="block">Apache Kafka enterprise messing hub stream connector.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList">
+<ul class="blockList">
+<li class="blockList"><a name="quarks.connectors.kafka">
+<!--   -->
+</a>
+<h3>Uses of <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a> in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Method parameters in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a> with type arguments of type <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;</code></td>
+<td class="colLast"><span class="typeNameLabel">KafkaConsumer.</span><code><span class="memberNameLink"><a href="../../../../quarks/connectors/kafka/KafkaConsumer.html#subscribeBytes-quarks.function.Function-java.lang.String...-">subscribeBytes</a></span>(<a href="../../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+              java.lang.String...&nbsp;topics)</code>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.ByteConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
new file mode 100644
index 0000000..ec959ef
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
@@ -0,0 +1,176 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
+<title>Uses of Interface quarks.connectors.kafka.KafkaConsumer.ConsumerRecord (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.ConsumerRecord (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.ConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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">
+<h2 title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.ConsumerRecord" class="title">Uses of Interface<br>quarks.connectors.kafka.KafkaConsumer.ConsumerRecord</h2>
+</div>
+<div class="classUseContainer">
+<ul class="blockList">
+<li class="blockList">
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing packages, and an explanation">
+<caption><span>Packages that use <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Package</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="#quarks.connectors.kafka">quarks.connectors.kafka</a></td>
+<td class="colLast">
+<div class="block">Apache Kafka enterprise messing hub stream connector.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList">
+<ul class="blockList">
+<li class="blockList"><a name="quarks.connectors.kafka">
+<!--   -->
+</a>
+<h3>Uses of <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a> in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing subinterfaces, and an explanation">
+<caption><span>Subinterfaces of <a href="../../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a> in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Interface and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>static interface&nbsp;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a></span></code>
+<div class="block">A Kafka record with byte[] typed key and value members</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><code>static interface&nbsp;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a></span></code>
+<div class="block">A Kafka record with String typed key and value members</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.ConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
new file mode 100644
index 0000000..003df66
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
@@ -0,0 +1,172 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
+<title>Uses of Interface quarks.connectors.kafka.KafkaConsumer.StringConsumerRecord (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.StringConsumerRecord (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.StringConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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">
+<h2 title="Uses of Interface quarks.connectors.kafka.KafkaConsumer.StringConsumerRecord" class="title">Uses of Interface<br>quarks.connectors.kafka.KafkaConsumer.StringConsumerRecord</h2>
+</div>
+<div class="classUseContainer">
+<ul class="blockList">
+<li class="blockList">
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing packages, and an explanation">
+<caption><span>Packages that use <a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Package</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="#quarks.connectors.kafka">quarks.connectors.kafka</a></td>
+<td class="colLast">
+<div class="block">Apache Kafka enterprise messing hub stream connector.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList">
+<ul class="blockList">
+<li class="blockList"><a name="quarks.connectors.kafka">
+<!--   -->
+</a>
+<h3>Uses of <a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a> in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a></h3>
+<table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing methods, and an explanation">
+<caption><span>Method parameters in <a href="../../../../quarks/connectors/kafka/package-summary.html">quarks.connectors.kafka</a> with type arguments of type <a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a></span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Modifier and Type</th>
+<th class="colLast" scope="col">Method and Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><code>&lt;T&gt;&nbsp;<a href="../../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a>&lt;T&gt;</code></td>
+<td class="colLast"><span class="typeNameLabel">KafkaConsumer.</span><code><span class="memberNameLink"><a href="../../../../quarks/connectors/kafka/KafkaConsumer.html#subscribe-quarks.function.Function-java.lang.String...-">subscribe</a></span>(<a href="../../../../quarks/function/Function.html" title="interface in quarks.function">Function</a>&lt;<a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T&gt;&nbsp;toTupleFn,
+         java.lang.String...&nbsp;topics)</code>
+<div class="block">Subscribe to the specified topics and yield a stream of tuples
+ from the published Kafka records.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+</ul>
+</li>
+</ul>
+</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.StringConsumerRecord.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
new file mode 100644
index 0000000..e9b6130
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
@@ -0,0 +1,126 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
+<title>Uses of Class quarks.connectors.kafka.KafkaConsumer (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="Uses of Class quarks.connectors.kafka.KafkaConsumer (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.html" title="class in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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">
+<h2 title="Uses of Class quarks.connectors.kafka.KafkaConsumer" class="title">Uses of Class<br>quarks.connectors.kafka.KafkaConsumer</h2>
+</div>
+<div class="classUseContainer">No usage of quarks.connectors.kafka.KafkaConsumer</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaConsumer.html" title="class in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaConsumer.html" target="_top">Frames</a></li>
+<li><a href="KafkaConsumer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
new file mode 100644
index 0000000..fe66f15
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
@@ -0,0 +1,126 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:47 UTC 2016 -->
+<title>Uses of Class quarks.connectors.kafka.KafkaProducer (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="Uses of Class quarks.connectors.kafka.KafkaProducer (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaProducer.html" target="_top">Frames</a></li>
+<li><a href="KafkaProducer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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">
+<h2 title="Uses of Class quarks.connectors.kafka.KafkaProducer" class="title">Uses of Class<br>quarks.connectors.kafka.KafkaProducer</h2>
+</div>
+<div class="classUseContainer">No usage of quarks.connectors.kafka.KafkaProducer</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../../overview-summary.html">Overview</a></li>
+<li><a href="../package-summary.html">Package</a></li>
+<li><a href="../../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka">Class</a></li>
+<li class="navBarCell1Rev">Use</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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li>Prev</li>
+<li>Next</li>
+</ul>
+<ul class="navList">
+<li><a href="../../../../index.html?quarks/connectors/kafka/class-use/KafkaProducer.html" target="_top">Frames</a></li>
+<li><a href="KafkaProducer.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/package-frame.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/package-frame.html b/site/javadoc/lastest/quarks/connectors/kafka/package-frame.html
new file mode 100644
index 0000000..fcabe79
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/package-frame.html
@@ -0,0 +1,27 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:46 UTC 2016 -->
+<title>quarks.connectors.kafka (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../script.js"></script>
+</head>
+<body>
+<h1 class="bar"><a href="../../../quarks/connectors/kafka/package-summary.html" target="classFrame">quarks.connectors.kafka</a></h1>
+<div class="indexContainer">
+<h2 title="Interfaces">Interfaces</h2>
+<ul title="Interfaces">
+<li><a href="KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka" target="classFrame"><span class="interfaceName">KafkaConsumer.ByteConsumerRecord</span></a></li>
+<li><a href="KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka" target="classFrame"><span class="interfaceName">KafkaConsumer.ConsumerRecord</span></a></li>
+<li><a href="KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka" target="classFrame"><span class="interfaceName">KafkaConsumer.StringConsumerRecord</span></a></li>
+</ul>
+<h2 title="Classes">Classes</h2>
+<ul title="Classes">
+<li><a href="KafkaConsumer.html" title="class in quarks.connectors.kafka" target="classFrame">KafkaConsumer</a></li>
+<li><a href="KafkaProducer.html" title="class in quarks.connectors.kafka" target="classFrame">KafkaProducer</a></li>
+</ul>
+</div>
+</body>
+</html>

http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/9f47ca2f/site/javadoc/lastest/quarks/connectors/kafka/package-summary.html
----------------------------------------------------------------------
diff --git a/site/javadoc/lastest/quarks/connectors/kafka/package-summary.html b/site/javadoc/lastest/quarks/connectors/kafka/package-summary.html
new file mode 100644
index 0000000..c5a5ca9
--- /dev/null
+++ b/site/javadoc/lastest/quarks/connectors/kafka/package-summary.html
@@ -0,0 +1,200 @@
+<!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 (1.8.0_71) on Tue May 17 00:28:46 UTC 2016 -->
+<title>quarks.connectors.kafka (Quarks v0.4.0)</title>
+<meta name="date" content="2016-05-17">
+<link rel="stylesheet" type="text/css" href="../../../stylesheet.css" title="Style">
+<script type="text/javascript" src="../../../script.js"></script>
+</head>
+<body>
+<script type="text/javascript"><!--
+    try {
+        if (location.href.indexOf('is-external=true') == -1) {
+            parent.document.title="quarks.connectors.kafka (Quarks v0.4.0)";
+        }
+    }
+    catch(err) {
+    }
+//-->
+</script>
+<noscript>
+<div>JavaScript is disabled on your browser.</div>
+</noscript>
+<!-- ========= START OF TOP NAVBAR ======= -->
+<div class="topNav"><a name="navbar.top">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.top.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li class="navBarCell1Rev">Package</li>
+<li>Class</li>
+<li><a href="package-use.html">Use</a></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="../../../quarks/connectors/jdbc/package-summary.html">Prev&nbsp;Package</a></li>
+<li><a href="../../../quarks/connectors/mqtt/package-summary.html">Next&nbsp;Package</a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/package-summary.html" target="_top">Frames</a></li>
+<li><a href="package-summary.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_top">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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&nbsp;quarks.connectors.kafka</h1>
+<div class="docSummary">
+<div class="block">Apache Kafka enterprise messing hub stream connector.</div>
+</div>
+<p>See:&nbsp;<a href="#package.description">Description</a></p>
+</div>
+<div class="contentContainer">
+<ul class="blockList">
+<li class="blockList">
+<table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Interface Summary table, listing interfaces, and an explanation">
+<caption><span>Interface Summary</span><span class="tabEnd">&nbsp;</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="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a></td>
+<td class="colLast">
+<div class="block">A Kafka record with byte[] typed key and value members</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a>&lt;K,V&gt;</td>
+<td class="colLast">
+<div class="block">A received Kafka record</div>
+</td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a></td>
+<td class="colLast">
+<div class="block">A Kafka record with String typed key and value members</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList">
+<table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Class Summary table, listing classes, and an explanation">
+<caption><span>Class Summary</span><span class="tabEnd">&nbsp;</span></caption>
+<tr>
+<th class="colFirst" scope="col">Class</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../quarks/connectors/kafka/KafkaConsumer.html" title="class in quarks.connectors.kafka">KafkaConsumer</a></td>
+<td class="colLast">
+<div class="block"><code>KafkaConsumer</code> is a connector for creating a stream of tuples
+ by subscribing to Apache Kafka messaging system topics.</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka">KafkaProducer</a></td>
+<td class="colLast">
+<div class="block"><code>KafkaProducer</code> is a connector for publishing a stream of tuples
+ to Apache Kafka messaging system topics.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+</ul>
+<a name="package.description">
+<!--   -->
+</a>
+<h2 title="Package quarks.connectors.kafka Description">Package quarks.connectors.kafka Description</h2>
+<div class="block">Apache Kafka enterprise messing hub stream connector.
+ <p>
+ The connector uses and includes components from the Kafka 0.8.2.2 release.
+ It has been successfully tested against a kafka_2.11-0.9.0.0 server as well.
+ <p>
+ Stream tuples may be published to Kafka broker topics
+ and created by subscribing to broker topics.
+ For more information about Kafka see
+ <a href="http://kafka.apache.org">http://kafka.apache.org</a></div>
+</div>
+<!-- ======= START OF BOTTOM NAVBAR ====== -->
+<div class="bottomNav"><a name="navbar.bottom">
+<!--   -->
+</a>
+<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
+<a name="navbar.bottom.firstrow">
+<!--   -->
+</a>
+<ul class="navList" title="Navigation">
+<li><a href="../../../overview-summary.html">Overview</a></li>
+<li class="navBarCell1Rev">Package</li>
+<li>Class</li>
+<li><a href="package-use.html">Use</a></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 class="aboutLanguage"><a href="http://quarks.incubator.apache.org">Apache Quarks (incubating)</a></div>
+</div>
+<div class="subNav">
+<ul class="navList">
+<li><a href="../../../quarks/connectors/jdbc/package-summary.html">Prev&nbsp;Package</a></li>
+<li><a href="../../../quarks/connectors/mqtt/package-summary.html">Next&nbsp;Package</a></li>
+</ul>
+<ul class="navList">
+<li><a href="../../../index.html?quarks/connectors/kafka/package-summary.html" target="_top">Frames</a></li>
+<li><a href="package-summary.html" target="_top">No&nbsp;Frames</a></li>
+</ul>
+<ul class="navList" id="allclasses_navbar_bottom">
+<li><a href="../../../allclasses-noframe.html">All&nbsp;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 ======= -->
+<p class="legalCopy"><small>Copyright &copy; 2016 The Apache Software Foundation. All Rights Reserved - d6cdfc6-20160517-0028</small></p>
+</body>
+</html>


Mime
View raw message