You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by qu...@apache.org on 2016/07/26 22:31:10 UTC
[26/51] [partial] incubator-quarks-website git commit: from
05ad5e885c21d745f87c23c280f222cbca457b89
http://git-wip-us.apache.org/repos/asf/incubator-quarks-website/blob/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html b/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html
deleted file mode 100644
index a7df138..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html
+++ /dev/null
@@ -1,200 +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 (1.8.0_71) on Tue May 17 00:28:45 UTC 2016 -->
-<title>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="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 class="navBarCell1Rev">Class</li>
-<li><a href="class-use/KafkaConsumer.StringConsumerRecord.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.ConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" target="_top">Frames</a></li>
-<li><a href="KafkaConsumer.StringConsumerRecord.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>Method</li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li>Constr | </li>
-<li>Method</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="Interface KafkaConsumer.StringConsumerRecord" class="title">Interface KafkaConsumer.StringConsumerRecord</h2>
-</div>
-<div class="contentContainer">
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt>All Superinterfaces:</dt>
-<dd><a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a><java.lang.String,java.lang.String></dd>
-</dl>
-<dl>
-<dt>Enclosing class:</dt>
-<dd><a href="../../../quarks/connectors/kafka/KafkaConsumer.html" title="class in quarks.connectors.kafka">KafkaConsumer</a></dd>
-</dl>
-<hr>
-<br>
-<pre>public static interface <span class="typeNameLabel">KafkaConsumer.StringConsumerRecord</span>
-extends <a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a><java.lang.String,java.lang.String></pre>
-<div class="block">A Kafka record with String typed key and value members</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>
-<ul class="blockList">
-<li class="blockList"><a name="methods.inherited.from.class.quarks.connectors.kafka.KafkaConsumer.ConsumerRecord">
-<!-- -->
-</a>
-<h3>Methods inherited from interface quarks.connectors.kafka.<a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ConsumerRecord</a></h3>
-<code><a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html#key--">key</a>, <a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html#offset--">offset</a>, <a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html#partition--">partition</a>, <a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html#topic--">topic</a>, <a href="../../../quarks/connectors/kafka/KafkaConsumer.ConsumerRecord.html#value--">value</a></code></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.StringConsumerRecord.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.ConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Prev Class</span></a></li>
-<li><a href="../../../quarks/connectors/kafka/KafkaProducer.html" title="class in quarks.connectors.kafka"><span class="typeNameLink">Next Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a href="../../../index.html?quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" target="_top">Frames</a></li>
-<li><a href="KafkaConsumer.StringConsumerRecord.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>Method</li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li>Constr | </li>
-<li>Method</li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!-- -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html b/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
deleted file mode 100644
index 81c6e64..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/KafkaConsumer.html
+++ /dev/null
@@ -1,425 +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 (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 Class</li>
-<li><a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Next 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 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><a href="#nested.class.summary">Nested</a> | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </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<String,Object> config = new HashMap<>();
- config.put("zookeeper.connect", zookeeperConnect);
- config.put("groupId", groupId);
-
- Topology t = ...
- KafkaConsumer kafka = new KafkaConsumer(t, () -> config);
-
- // subscribe to a topic where sensor readings are published as JSON,
- // creating a stream of JSON tuples
- TStream<String> sensorReadingsJson =
- kafka.subscribe(rec -> 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"> </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 </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 </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><<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>></span></code>
-<div class="block">A received Kafka record</div>
-</td>
-</tr>
-<tr class="altColor">
-<td class="colFirst"><code>static interface </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"> </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> t,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><java.util.Map<java.lang.String,java.lang.Object>> 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"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </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><T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T></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><<a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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><T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T></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><<a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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 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 KafkaConsumer(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> t,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><java.util.Map<java.lang.String,java.lang.Object>> 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 <T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> subscribeBytes(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><<a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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 <T> <a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> subscribe(<a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><<a href="../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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 Class</li>
-<li><a href="../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka"><span class="typeNameLink">Next 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 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><a href="#nested.class.summary">Nested</a> | </li>
-<li>Field | </li>
-<li><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </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 © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html b/content/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
deleted file mode 100644
index c58c0a6..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/KafkaProducer.html
+++ /dev/null
@@ -1,436 +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 (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 Class</span></a></li>
-<li>Next 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 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><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </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<String,Object> config = new HashMap<>();
- config.put("bootstrap.servers", bootstrapServers);
-
- Topology t = ...
- KafkaProducer kafka = new KafkaProducer(t, () -> config);
-
- TStream<JsonObject> sensorReadings = t.poll(
- () -> getSensorReading(), 5, TimeUnit.SECONDS);
-
- // publish as sensor readings as JSON
- kafka.publish(sensonReadings, tuple -> 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"> </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> t,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><java.util.Map<java.lang.String,java.lang.Object>> 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"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </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><java.lang.String></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><java.lang.String> stream,
- java.lang.String 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><T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T></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><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> keyFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> valueFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topicFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> 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><T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T></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><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> keyFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> valueFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topicFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> 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 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 KafkaProducer(<a href="../../../quarks/topology/Topology.html" title="interface in quarks.topology">Topology</a> t,
- <a href="../../../quarks/function/Supplier.html" title="interface in quarks.function">Supplier</a><java.util.Map<java.lang.String,java.lang.Object>> 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 <T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T> publishBytes(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> keyFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,byte[]> valueFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topicFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> 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 <T> <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><T> publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T> stream,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> keyFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> valueFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.String> topicFn,
- <a href="../../../quarks/function/Function.html" title="interface in quarks.function">Function</a><T,java.lang.Integer> 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 <a href="../../../quarks/topology/TSink.html" title="interface in quarks.topology">TSink</a><java.lang.String> publish(<a href="../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><java.lang.String> stream,
- java.lang.String 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 Class</span></a></li>
-<li>Next 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 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><a href="#constructor.summary">Constr</a> | </li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail: </li>
-<li>Field | </li>
-<li><a href="#constructor.detail">Constr</a> | </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 © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html b/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
deleted file mode 100644
index 7079108..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ByteConsumerRecord.html
+++ /dev/null
@@ -1,172 +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 (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 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">
-<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"> </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"> </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><T> <a href="../../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T></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><<a href="../../../../quarks/connectors/kafka/KafkaConsumer.ByteConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.ByteConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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 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 ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html b/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
deleted file mode 100644
index ec959ef..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.ConsumerRecord.html
+++ /dev/null
@@ -1,176 +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 (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 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">
-<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"> </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"> </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 </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 </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 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 ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html b/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
deleted file mode 100644
index 003df66..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.StringConsumerRecord.html
+++ /dev/null
@@ -1,172 +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 (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 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">
-<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"> </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"> </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><T> <a href="../../../../quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a><T></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><<a href="../../../../quarks/connectors/kafka/KafkaConsumer.StringConsumerRecord.html" title="interface in quarks.connectors.kafka">KafkaConsumer.StringConsumerRecord</a>,T> toTupleFn,
- java.lang.String... 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 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 ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html b/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
deleted file mode 100644
index e9b6130..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaConsumer.html
+++ /dev/null
@@ -1,126 +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 (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 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">
-<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 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 ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html b/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
deleted file mode 100644
index fe66f15..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/class-use/KafkaProducer.html
+++ /dev/null
@@ -1,126 +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 (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 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">
-<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 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 ======= -->
-<p class="legalCopy"><small>Copyright © 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/a13739b3/content/javadoc/lastest/quarks/connectors/kafka/package-frame.html
----------------------------------------------------------------------
diff --git a/content/javadoc/lastest/quarks/connectors/kafka/package-frame.html b/content/javadoc/lastest/quarks/connectors/kafka/package-frame.html
deleted file mode 100644
index fcabe79..0000000
--- a/content/javadoc/lastest/quarks/connectors/kafka/package-frame.html
+++ /dev/null
@@ -1,27 +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 (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>