http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html b/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html index 669da80..f54f9d6 100644 --- a/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html +++ b/0110/javadoc/org/apache/kafka/connect/sink/SinkTask.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 --> -<title>SinkTask (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:18 GMT 2017 --> +<title>SinkTask (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SinkTask (kafka 0.11.0.1 API)"; + parent.document.title="SinkTask (kafka 0.11.0.2 API)"; } //--> </script> @@ -83,7 +83,7 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li>java.lang.Object</li> <li> <ul class="inheritance"> <li>org.apache.kafka.connect.sink.SinkTask</li> @@ -100,7 +100,7 @@ <hr> <br> <pre>public abstract class <span class="strong">SinkTask</span> -extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> +extends java.lang.Object implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" title="interface in org.apache.kafka.connect.connector">Task</a></pre> <div class="block">SinkTask is a Task that takes records loaded from Kafka and sends them to another system. Each task instance is assigned a set of partitions by the Connect framework and will handle all records received @@ -150,7 +150,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#context">context</a></strong></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colFirst"><code>static java.lang.String</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#TOPICS_CONFIG">TOPICS_CONFIG</a></strong></code> <div class="block"> The configuration key that provides the list of topics that are inputs for this @@ -191,14 +191,14 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#close(java.util.Collection)">close</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#close(java.util.Collection)">close</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> <div class="block">The SinkTask use this method to close writers for partitions that are no longer assigned to the SinkTask.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#flush(java.util.Map)">flush</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#flush(java.util.Map)">flush</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</code> <div class="block">Flush all records that have been <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#put(java.util.Collection)"><code>put(Collection)</code></a> for the specified topic-partitions.</div> </td> </tr> @@ -210,7 +210,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#onPartitionsAssigned(java.util.Collection)">onPartitionsAssigned</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#onPartitionsAssigned(java.util.Collection)">onPartitionsAssigned</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> <div class="block"><strong>Deprecated.</strong> <div class="block"><i>Use <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#open(java.util.Collection)"><code>open(Collection)</code></a> for partition initialization.</i></div> </div> @@ -218,7 +218,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#onPartitionsRevoked(java.util.Collection)">onPartitionsRevoked</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#onPartitionsRevoked(java.util.Collection)">onPartitionsRevoked</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> <div class="block"><strong>Deprecated.</strong> <div class="block"><i>Use <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#close(java.util.Collection)"><code>close(Collection)</code></a> instead for partition cleanup.</i></div> </div> @@ -226,26 +226,26 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#open(java.util.Collection)">open</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#open(java.util.Collection)">open</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</code> <div class="block">The SinkTask use this method to create writers for newly assigned partitions in case of partition rebalance.</div> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#preCommit(java.util.Map)">preCommit</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</code> +<td class="colFirst"><code>java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#preCommit(java.util.Map)">preCommit</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</code> <div class="block">Pre-commit hook invoked prior to an offset commit.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>abstract void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#put(java.util.Collection)">put</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink">SinkRecord</a>> records)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#put(java.util.Collection)">put</a></strong>(java.util.Collection<<a href="../../../../../org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink">SinkRecord</a>> records)</code> <div class="block">Put the records in the sink.</div> </td> </tr> <tr class="altColor"> <td class="colFirst"><code>abstract void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#start(java.util.Map)">start</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> props)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#start(java.util.Map)">start</a></strong>(java.util.Map<java.lang.String,java.lang.String> props)</code> <div class="block">Start the Task.</div> </td> </tr> @@ -260,8 +260,8 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> -<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li> +<h3>Methods inherited from class java.lang.Object</h3> +<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods_inherited_from_class_org.apache.kafka.connect.connector.Task"> @@ -290,7 +290,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>TOPICS_CONFIG</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> TOPICS_CONFIG</pre> +<pre>public static final java.lang.String TOPICS_CONFIG</pre> <div class="block"><p> The configuration key that provides the list of topics that are inputs for this SinkTask. @@ -350,7 +350,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>public abstract void start(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>> props)</pre> +<pre>public abstract void start(java.util.Map<java.lang.String,java.lang.String> props)</pre> <div class="block">Start the Task. This should handle any configuration parsing and one-time setup of the task.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -364,7 +364,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>put</h4> -<pre>public abstract void put(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink">SinkRecord</a>> records)</pre> +<pre>public abstract void put(java.util.Collection<<a href="../../../../../org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink">SinkRecord</a>> records)</pre> <div class="block">Put the records in the sink. Usually this should send the records to the sink asynchronously and immediately return. @@ -381,7 +381,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>flush</h4> -<pre>public void flush(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</pre> +<pre>public void flush(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</pre> <div class="block">Flush all records that have been <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#put(java.util.Collection)"><code>put(Collection)</code></a> for the specified topic-partitions.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>currentOffsets</code> - the current offset state as of the last call to <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#put(java.util.Collection)"><code>put(Collection)</code></a>}, provided for convenience but could also be determined by tracking all offsets included in the <a href="../../../../../org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink"><code>SinkRecord</code></a>s @@ -394,7 +394,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>preCommit</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> preCommit(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</pre> +<pre>public java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> preCommit(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="../../../../../org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a>> currentOffsets)</pre> <div class="block">Pre-commit hook invoked prior to an offset commit. The default implementation simply invokes <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#flush(java.util.Map)"><code>flush(Map)</code></a> and is thus able to assume all <code>currentOffsets</code> are safe to commit.</div> @@ -410,7 +410,7 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>open</h4> -<pre>public void open(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> +<pre>public void open(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> <div class="block">The SinkTask use this method to create writers for newly assigned partitions in case of partition rebalance. This method will be called after partition re-assignment completes and before the SinkTask starts fetching data. Note that any errors raised from this method will cause the task to stop.</div> @@ -424,8 +424,8 @@ implements <a href="../../../../../org/apache/kafka/connect/connector/Task.html" <ul class="blockList"> <li class="blockList"> <h4>onPartitionsAssigned</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void onPartitionsAssigned(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> +<pre>@Deprecated +public void onPartitionsAssigned(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> <div class="block"><span class="strong">Deprecated.</span> <i>Use <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#open(java.util.Collection)"><code>open(Collection)</code></a> for partition initialization.</i></div> </li> </ul> @@ -435,7 +435,7 @@ public void onPartitionsAssigned(<a href="http://docs.oracle.com/javas <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>public void close(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> +<pre>public void close(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> <div class="block">The SinkTask use this method to close writers for partitions that are no longer assigned to the SinkTask. This method will be called before a rebalance operation starts and after the SinkTask stops fetching data. After being closed, Connect will not write @@ -450,8 +450,8 @@ public void onPartitionsAssigned(<a href="http://docs.oracle.com/javas <ul class="blockList"> <li class="blockList"> <h4>onPartitionsRevoked</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void onPartitionsRevoked(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> +<pre>@Deprecated +public void onPartitionsRevoked(java.util.Collection<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> partitions)</pre> <div class="block"><span class="strong">Deprecated.</span> <i>Use <a href="../../../../../org/apache/kafka/connect/sink/SinkTask.html#close(java.util.Collection)"><code>close(Collection)</code></a> instead for partition cleanup.</i></div> </li> </ul>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html b/0110/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html index 1785c11..c6587b8 100644 --- a/0110/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html +++ b/0110/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:58 BST 2017 --> -<title>SinkTaskContext (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:18 GMT 2017 --> +<title>SinkTaskContext (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SinkTaskContext (kafka 0.11.0.1 API)"; + parent.document.title="SinkTaskContext (kafka 0.11.0.2 API)"; } //--> </script> @@ -108,14 +108,14 @@ <th class="colLast" scope="col">Method and Description</th> </tr> <tr class="altColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>></code></td> +<td class="colFirst"><code>java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTaskContext.html#assignment()">assignment</a></strong>()</code> <div class="block">Get the current set of assigned TopicPartitions for this task.</div> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTaskContext.html#offset(java.util.Map)">offset</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> offsets)</code> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/sink/SinkTaskContext.html#offset(java.util.Map)">offset</a></strong>(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,java.lang.Long> offsets)</code> <div class="block">Reset the consumer offsets for the given topic partitions.</div> </td> </tr> @@ -171,7 +171,7 @@ <ul class="blockList"> <li class="blockList"> <h4>offset</h4> -<pre>void offset(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a>> offsets)</pre> +<pre>void offset(java.util.Map<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>,java.lang.Long> offsets)</pre> <div class="block">Reset the consumer offsets for the given topic partitions. SinkTasks should use this if they manage offsets in the sink data store rather than using Kafka consumer offsets. For example, an HDFS connector might record offsets in HDFS to provide exactly once delivery. When the SinkTask is started or a rebalance occurs, the task @@ -218,7 +218,7 @@ <ul class="blockList"> <li class="blockList"> <h4>assignment</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> assignment()</pre> +<pre>java.util.Set<<a href="../../../../../org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a>> assignment()</pre> <div class="block">Get the current set of assigned TopicPartitions for this task.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>the set of currently assigned TopicPartitions</dd></dl> </li> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/package-frame.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/package-frame.html b/0110/javadoc/org/apache/kafka/connect/sink/package-frame.html index 9d12a9e..179b9d4 100644 --- a/0110/javadoc/org/apache/kafka/connect/sink/package-frame.html +++ b/0110/javadoc/org/apache/kafka/connect/sink/package-frame.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 --> -<title>org.apache.kafka.connect.sink (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 --> +<title>org.apache.kafka.connect.sink (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/package-summary.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/package-summary.html b/0110/javadoc/org/apache/kafka/connect/sink/package-summary.html index 84e1da1..152b629 100644 --- a/0110/javadoc/org/apache/kafka/connect/sink/package-summary.html +++ b/0110/javadoc/org/apache/kafka/connect/sink/package-summary.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 --> -<title>org.apache.kafka.connect.sink (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 --> +<title>org.apache.kafka.connect.sink (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.kafka.connect.sink (kafka 0.11.0.1 API)"; + parent.document.title="org.apache.kafka.connect.sink (kafka 0.11.0.2 API)"; } //--> </script> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/sink/package-tree.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/sink/package-tree.html b/0110/javadoc/org/apache/kafka/connect/sink/package-tree.html index 9bfc32d..e8cdafb 100644 --- a/0110/javadoc/org/apache/kafka/connect/sink/package-tree.html +++ b/0110/javadoc/org/apache/kafka/connect/sink/package-tree.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:59 BST 2017 --> -<title>org.apache.kafka.connect.sink Class Hierarchy (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:19 GMT 2017 --> +<title>org.apache.kafka.connect.sink Class Hierarchy (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.kafka.connect.sink Class Hierarchy (kafka 0.11.0.1 API)"; + parent.document.title="org.apache.kafka.connect.sink Class Hierarchy (kafka 0.11.0.2 API)"; } //--> </script> @@ -71,7 +71,7 @@ <div class="contentContainer"> <h2 title="Class Hierarchy">Class Hierarchy</h2> <ul> -<li type="circle">java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang"><span class="strong">Object</span></a> +<li type="circle">java.lang.Object <ul> <li type="circle">org.apache.kafka.connect.connector.<a href="../../../../../org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector"><span class="strong">Connector</span></a> <ul> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/source/SourceConnector.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/source/SourceConnector.html b/0110/javadoc/org/apache/kafka/connect/source/SourceConnector.html index 14602e6..2e8e262 100644 --- a/0110/javadoc/org/apache/kafka/connect/source/SourceConnector.html +++ b/0110/javadoc/org/apache/kafka/connect/source/SourceConnector.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 --> -<title>SourceConnector (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 --> +<title>SourceConnector (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SourceConnector (kafka 0.11.0.1 API)"; + parent.document.title="SourceConnector (kafka 0.11.0.2 API)"; } //--> </script> @@ -83,7 +83,7 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li>java.lang.Object</li> <li> <ul class="inheritance"> <li><a href="../../../../../org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector">org.apache.kafka.connect.connector.Connector</a></li> @@ -159,8 +159,8 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/Connector.htm <li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> -<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString()" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li> +<h3>Methods inherited from class java.lang.Object</h3> +<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ae86b7d5/0110/javadoc/org/apache/kafka/connect/source/SourceRecord.html ---------------------------------------------------------------------- diff --git a/0110/javadoc/org/apache/kafka/connect/source/SourceRecord.html b/0110/javadoc/org/apache/kafka/connect/source/SourceRecord.html index b57c254..91f3f4f 100644 --- a/0110/javadoc/org/apache/kafka/connect/source/SourceRecord.html +++ b/0110/javadoc/org/apache/kafka/connect/source/SourceRecord.html @@ -2,15 +2,15 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (version 1.7.0_79) on Tue Sep 05 19:20:56 BST 2017 --> -<title>SourceRecord (kafka 0.11.0.1 API)</title> -<meta name="date" content="2017-09-05"> +<!-- Generated by javadoc (version 1.7.0_80) on Fri Nov 10 23:49:17 GMT 2017 --> +<title>SourceRecord (kafka 0.11.0.2 API)</title> +<meta name="date" content="2017-11-10"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> </head> <body> <script type="text/javascript"><!-- if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SourceRecord (kafka 0.11.0.1 API)"; + parent.document.title="SourceRecord (kafka 0.11.0.2 API)"; } //--> </script> @@ -83,7 +83,7 @@ </div> <div class="contentContainer"> <ul class="inheritance"> -<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object</a></li> +<li>java.lang.Object</li> <li> <ul class="inheritance"> <li><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">org.apache.kafka.connect.connector.ConnectRecord</a><<a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a>></li> @@ -136,49 +136,49 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <th class="colOne" scope="col">Constructor and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</code> </td> + java.lang.Object value)</code> </td> </tr> <tr class="rowColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</code> </td> + java.lang.Object value)</code> </td> </tr> <tr class="altColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20java.lang.Long)">SourceRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20java.lang.Long)">SourceRecord</a></strong>(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a> timestamp)</code> </td> + java.lang.Object value, + java.lang.Long timestamp)</code> </td> </tr> <tr class="rowColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</code> </td> + java.lang.Object value)</code> </td> </tr> <tr class="altColor"> -<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, +<td class="colOne"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#SourceRecord(java.util.Map,%20java.util.Map,%20java.lang.String,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object)">SourceRecord</a></strong>(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</code> </td> + java.lang.Object value)</code> </td> </tr> </table> </li> @@ -197,7 +197,7 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord </tr> <tr class="altColor"> <td class="colFirst"><code>boolean</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#equals(java.lang.Object)">equals</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> o)</code> </td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#equals(java.lang.Object)">equals</a></strong>(java.lang.Object o)</code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>int</code></td> @@ -205,26 +205,26 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord </tr> <tr class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#newRecord(java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20java.lang.Long)">newRecord</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> kafkaPartition, +<td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#newRecord(java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20java.lang.Long)">newRecord</a></strong>(java.lang.String topic, + java.lang.Integer kafkaPartition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a> timestamp)</code> + java.lang.Object value, + java.lang.Long timestamp)</code> <div class="block">Generate a new record of the same type as itself, with the specified parameter values.</div> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?></code></td> +<td class="colFirst"><code>java.util.Map<java.lang.String,?></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#sourceOffset()">sourceOffset</a></strong>()</code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?></code></td> +<td class="colFirst"><code>java.util.Map<java.lang.String,?></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#sourcePartition()">sourcePartition</a></strong>()</code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colFirst"><code>java.lang.String</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html#toString()">toString</a></strong>()</code> </td> </tr> </table> @@ -239,8 +239,8 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <li class="blockList"><a name="methods_inherited_from_class_java.lang.Object"> <!-- --> </a> -<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> -<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone()" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize()" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass()" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify()" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notifyAll()" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait()" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-ex ternal=true#wait(long)" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait(long,%20int)" title="class or interface in java.lang">wait</a></code></li> +<h3>Methods inherited from class java.lang.Object</h3> +<code>clone, finalize, getClass, notify, notifyAll, wait, wait, wait</code></li> </ul> </li> </ul> @@ -262,12 +262,12 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>SourceRecord</h4> -<pre>public SourceRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<pre>public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</pre> + java.lang.Object value)</pre> </li> </ul> <a name="SourceRecord(java.util.Map, java.util.Map, java.lang.String, org.apache.kafka.connect.data.Schema, java.lang.Object)"> @@ -276,11 +276,11 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>SourceRecord</h4> -<pre>public SourceRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, +<pre>public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</pre> + java.lang.Object value)</pre> </li> </ul> <a name="SourceRecord(java.util.Map, java.util.Map, java.lang.String, org.apache.kafka.connect.data.Schema, java.lang.Object, org.apache.kafka.connect.data.Schema, java.lang.Object)"> @@ -289,13 +289,13 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>SourceRecord</h4> -<pre>public SourceRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, +<pre>public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</pre> + java.lang.Object value)</pre> </li> </ul> <a name="SourceRecord(java.util.Map, java.util.Map, java.lang.String, java.lang.Integer, org.apache.kafka.connect.data.Schema, java.lang.Object, org.apache.kafka.connect.data.Schema, java.lang.Object)"> @@ -304,14 +304,14 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>SourceRecord</h4> -<pre>public SourceRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<pre>public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value)</pre> + java.lang.Object value)</pre> </li> </ul> <a name="SourceRecord(java.util.Map, java.util.Map, java.lang.String, java.lang.Integer, org.apache.kafka.connect.data.Schema, java.lang.Object, org.apache.kafka.connect.data.Schema, java.lang.Object, java.lang.Long)"> @@ -320,15 +320,15 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockListLast"> <li class="blockList"> <h4>SourceRecord</h4> -<pre>public SourceRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition, - <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> partition, +<pre>public SourceRecord(java.util.Map<java.lang.String,?> sourcePartition, + java.util.Map<java.lang.String,?> sourceOffset, + java.lang.String topic, + java.lang.Integer partition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a> timestamp)</pre> + java.lang.Object value, + java.lang.Long timestamp)</pre> </li> </ul> </li> @@ -345,7 +345,7 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>sourcePartition</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourcePartition()</pre> +<pre>public java.util.Map<java.lang.String,?> sourcePartition()</pre> </li> </ul> <a name="sourceOffset()"> @@ -354,7 +354,7 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>sourceOffset</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,?> sourceOffset()</pre> +<pre>public java.util.Map<java.lang.String,?> sourceOffset()</pre> </li> </ul> <a name="newRecord(java.lang.String, java.lang.Integer, org.apache.kafka.connect.data.Schema, java.lang.Object, org.apache.kafka.connect.data.Schema, java.lang.Object, java.lang.Long)"> @@ -363,13 +363,13 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>newRecord</h4> -<pre>public <a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a> newRecord(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> topic, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a> kafkaPartition, +<pre>public <a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a> newRecord(java.lang.String topic, + java.lang.Integer kafkaPartition, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> keySchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> key, + java.lang.Object key, <a href="../../../../../org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data">Schema</a> valueSchema, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> value, - <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Long.html?is-external=true"; title="class or interface in java.lang">Long</a> timestamp)</pre> + java.lang.Object value, + java.lang.Long timestamp)</pre> <div class="block"><strong>Description copied from class: <code><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html#newRecord(java.lang.String,%20java.lang.Integer,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20org.apache.kafka.connect.data.Schema,%20java.lang.Object,%20java.lang.Long)">ConnectRecord</a></code></strong></div> <div class="block">Generate a new record of the same type as itself, with the specified parameter values.</div> <dl> @@ -384,7 +384,7 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockList"> <li class="blockList"> <h4>equals</h4> -<pre>public boolean equals(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> o)</pre> +<pre>public boolean equals(java.lang.Object o)</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html#equals(java.lang.Object)">equals</a></code> in class <code><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">ConnectRecord</a><<a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a>></code></dd> @@ -410,7 +410,7 @@ extends <a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord <ul class="blockListLast"> <li class="blockList"> <h4>toString</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> toString()</pre> +<pre>public java.lang.String toString()</pre> <dl> <dt><strong>Overrides:</strong></dt> <dd><code><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html#toString()">toString</a></code> in class <code><a href="../../../../../org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">ConnectRecord</a><<a href="../../../../../org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a>></code></dd>
