blob: 02328f5d831df4350d0f44024eeb004340b2a595 [file] [log] [blame]
<!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_40) on Thu Jul 20 13:19:02 PDT 2017 -->
<title>Index (gobblin-kafka-08 0.11.0 API)</title>
<meta name="date" content="2017-07-20">
<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="Index (gobblin-kafka-08 0.11.0 API)";
}
}
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>Package</li>
<li>Class</li>
<li><a href="overview-tree.html">Tree</a></li>
<li><a href="deprecated-list.html">Deprecated</a></li>
<li class="navBarCell1Rev">Index</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?index-all.html" target="_top">Frames</a></li>
<li><a href="index-all.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_top");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<a name="skip.navbar.top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<div class="contentContainer"><a href="#I:A">A</a>&nbsp;<a href="#I:B">B</a>&nbsp;<a href="#I:C">C</a>&nbsp;<a href="#I:D">D</a>&nbsp;<a href="#I:E">E</a>&nbsp;<a href="#I:F">F</a>&nbsp;<a href="#I:G">G</a>&nbsp;<a href="#I:I">I</a>&nbsp;<a href="#I:J">J</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:M">M</a>&nbsp;<a href="#I:N">N</a>&nbsp;<a href="#I:O">O</a>&nbsp;<a href="#I:P">P</a>&nbsp;<a href="#I:R">R</a>&nbsp;<a href="#I:S">S</a>&nbsp;<a href="#I:T">T</a>&nbsp;<a href="#I:U">U</a>&nbsp;<a href="#I:V">V</a>&nbsp;<a href="#I:W">W</a>&nbsp;<a href="#I:Z:Z_">_</a>&nbsp;<a name="I:A">
<!-- -->
</a>
<h2 class="title">A</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#addSpec-gobblin.runtime.api.Spec-">addSpec(Spec)</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:B">
<!-- -->
</a>
<h2 class="title">B</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#brokers">brokers</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#brokers">brokers</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html#build-java.lang.String-java.lang.String-">build(String, String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter.Builder</a></dt>
<dd>
<div class="block">Builds and returns <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroEventReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html#build-java.lang.String-java.lang.String-java.util.Properties-">build(String, String, Properties)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.Builder</a></dt>
<dd>
<div class="block">Builds and returns <a href="gobblin/metrics/kafka/KafkaAvroReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#build-java.lang.String-java.lang.String-">build(String, String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>
<div class="block">Builds and returns <a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaEventReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#build-java.lang.String-java.lang.String-java.util.Properties-">build(String, String, Properties)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>
<div class="block">Builds and returns <a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html#Builder--">Builder()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#Builder-gobblin.metrics.MetricContext-">Builder(MetricContext)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#Builder--">Builder()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderFactory.html#BuilderFactory--">BuilderFactory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.BuilderFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.BuilderFactory.html#BuilderFactory--">BuilderFactory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka">KafkaReporter.BuilderFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderImpl.html#BuilderImpl--">BuilderImpl()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.BuilderImpl</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.BuilderImpl.html#BuilderImpl--">BuilderImpl()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka">KafkaReporter.BuilderImpl</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:C">
<!-- -->
</a>
<h2 class="title">C</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#changedSpecs--">changedSpecs()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#changedSpecs--">changedSpecs()</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>
<div class="block">This method returns job specs receive from Kafka.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#close--">close()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/SimpleKafkaConsumer.html#close--">close()</a></span> - Method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/SimpleKafkaConsumer.html" title="class in gobblin.kafka.tool">SimpleKafkaConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#close--">close()</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaPusher.html#close--">close()</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka">KafkaPusher</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#close--">close()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#close--">close()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#close--">close()</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html#close--">close()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html" title="class in gobblin.source.extractor.extract.kafka">KafkaGsonDeserializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#close--">close()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_BUFFER_SIZE_BYTES">CONFIG_KAFKA_BUFFER_SIZE_BYTES</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_BUFFER_SIZE_BYTES_DEFAULT">CONFIG_KAFKA_BUFFER_SIZE_BYTES_DEFAULT</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_CLIENT_NAME">CONFIG_KAFKA_CLIENT_NAME</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_CLIENT_NAME_DEFAULT">CONFIG_KAFKA_CLIENT_NAME_DEFAULT</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_FETCH_OFFSET_NUM_TRIES">CONFIG_KAFKA_FETCH_OFFSET_NUM_TRIES</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_FETCH_REQUEST_CORRELATION_ID">CONFIG_KAFKA_FETCH_REQUEST_CORRELATION_ID</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_KAFKA_FETCH_TOPIC_NUM_TRIES">CONFIG_KAFKA_FETCH_TOPIC_NUM_TRIES</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#CONFIG_PREFIX">CONFIG_PREFIX</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html#configure-java.util.Map-boolean-">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html" title="class in gobblin.source.extractor.extract.kafka">KafkaGsonDeserializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#consume-gobblin.source.extractor.extract.kafka.KafkaPartition-long-long-">consume(KafkaPartition, long, long)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.Factory.html#create-com.typesafe.config.Config-">create(Config)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.Factory.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient.Factory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#create-gobblin.configuration.State-">create(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
<div class="block">Create a KafkaWrapper based on the given type of Kafka API and list of Kafka brokers.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaPusher.html#createProducer-kafka.producer.ProducerConfig-">createProducer(ProducerConfig)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka">KafkaPusher</a></dt>
<dd>
<div class="block">Actually creates the Kafka producer.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html#createSerializer-gobblin.metrics.reporter.util.SchemaVersionWriter-">createSerializer(SchemaVersionWriter)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.html#createSerializer-gobblin.metrics.reporter.util.SchemaVersionWriter-">createSerializer(SchemaVersionWriter)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.html#createSerializer-gobblin.metrics.reporter.util.SchemaVersionWriter-">createSerializer(SchemaVersionWriter)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka">KafkaEventReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#createSerializer-gobblin.metrics.reporter.util.SchemaVersionWriter-">createSerializer(SchemaVersionWriter)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:D">
<!-- -->
</a>
<h2 class="title">D</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html#decodeRecord-gobblin.kafka.client.ByteArrayBasedKafkaRecord-">decodeRecord(ByteArrayBasedKafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#deleteSpec-java.net.URI-">deleteSpec(URI)</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializer.html#deserialize-java.lang.String-byte:A-">deserialize(String, byte[])</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize">LiAvroDeserializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#deserialize-java.io.InputStream-">deserialize(InputStream)</a></span> - Static method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html#deserialize-java.lang.String-byte:A-">deserialize(String, byte[])</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html" title="class in gobblin.source.extractor.extract.kafka">KafkaGsonDeserializer</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:E">
<!-- -->
</a>
<h2 class="title">E</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#emitReport-gobblin.metrics.MetricReport-">emitReport(MetricReport)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#emptyCheckpoint--">emptyCheckpoint()</a></span> - Static method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/KafkaReportingFormats.html#eventReporterBuilder-gobblin.metrics.MetricContext-java.util.Properties-">eventReporterBuilder(MetricContext, Properties)</a></span> - Method in enum gobblin.metrics.<a href="gobblin/metrics/KafkaReportingFormats.html" title="enum in gobblin.metrics">KafkaReportingFormats</a></dt>
<dd>
<div class="block">Get a <a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaEventReporter.Builder</code></a> for this reporting format.</div>
</dd>
</dl>
<a name="I:F">
<!-- -->
</a>
<h2 class="title">F</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.Factory.html#Factory--">Factory()</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.Factory.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient.Factory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html#Factory--">Factory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter.Factory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html#Factory--">Factory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Factory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#fetchNextMessageBuffer-gobblin.source.extractor.extract.kafka.KafkaPartition-long-long-">fetchNextMessageBuffer(KafkaPartition, long, long)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#flush--">flush()</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html#forContext-gobblin.metrics.MetricContext-">forContext(MetricContext)</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter.Factory</a></dt>
<dd>
<div class="block">Returns a new <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroEventReporter.Builder</code></a> for <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroEventReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html#forContext-gobblin.metrics.MetricContext-">forContext(MetricContext)</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="block"><span class="deprecationComment">this method is bugged. Use <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html#forContext-gobblin.metrics.MetricContext-"><code>KafkaAvroEventReporter.Factory.forContext(gobblin.metrics.MetricContext)</code></a> instead.</span></div>
</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html#forContext-gobblin.metrics.MetricContext-">forContext(MetricContext)</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Factory</a></dt>
<dd>
<div class="block">Returns a new <a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaEventReporter.Builder</code></a> for <a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaEventReporter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.html#forContext-gobblin.metrics.MetricContext-">forContext(MetricContext)</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka">KafkaEventReporter</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="block"><span class="deprecationComment">this method is bugged. Use <a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html#forContext-gobblin.metrics.MetricContext-"><code>KafkaEventReporter.Factory.forContext(gobblin.metrics.MetricContext)</code></a> instead.</span></div>
</div>
</dd>
</dl>
<a name="I:G">
<!-- -->
</a>
<h2 class="title">G</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html#getAsyncDataWriter-java.util.Properties-">getAsyncDataWriter(Properties)</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">KafkaDataWriterBuilder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#getBrokers--">getBrokers()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#getCapabilities--">getCapabilities()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#getConfig--">getConfig()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#getDescription--">getDescription()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#getEarliestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getEarliestOffset(KafkaPartition)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#getEarliestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getEarliestOffset(KafkaPartition)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.html#getExtractor-gobblin.configuration.WorkUnitState-">getExtractor(WorkUnitState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#getFilteredTopics-java.util.List-java.util.List-">getFilteredTopics(List&lt;Pattern&gt;, List&lt;Pattern&gt;)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#getHealth--">getHealth()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#getKafkaProducer-java.util.Properties-">getKafkaProducer(Properties)</a></span> - Static method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html#getKeyBytes--">getKeyBytes()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient.Kafka08ConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#getLatestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getLatestOffset(KafkaPartition)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html#getLatestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getLatestOffset(KafkaPartition)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka">KafkaWrapper</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html#getMessageBytes--">getMessageBytes()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient.Kafka08ConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html#getSchema--">getSchema()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.html#getTopics--">getTopics()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#getUri--">getUri()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a> - package gobblin.kafka.client</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a> - package gobblin.kafka.serialize</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/tool/package-summary.html">gobblin.kafka.tool</a> - package gobblin.kafka.tool</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a> - package gobblin.kafka.writer</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/package-summary.html">gobblin.metrics</a> - package gobblin.metrics</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a> - package gobblin.metrics.kafka</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/service/package-summary.html">gobblin.service</a> - package gobblin.service</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a> - package gobblin.source.extractor.extract.kafka</dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:I">
<!-- -->
</a>
<h2 class="title">I</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#isEmpty--">isEmpty()</a></span> - Method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:J">
<!-- -->
</a>
<h2 class="title">J</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html#JobSpecListener--">JobSpecListener()</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:K">
<!-- -->
</a>
<h2 class="title">K</h2>
<dl>
<dt><a href="gobblin/kafka/client/Kafka08ConsumerClient.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka08ConsumerClient</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-kafka-common/gobblin/kafka/client/GobblinKafkaConsumerClient.html?is-external=true" title="class or interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a> that uses kafka 08 scala consumer client.</div>
</dd>
<dt><a href="gobblin/kafka/client/Kafka08ConsumerClient.Factory.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka08ConsumerClient.Factory</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka08ConsumerClient.Kafka08ConsumerRecord</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html#Kafka08ConsumerRecord-kafka.message.MessageAndOffset-">Kafka08ConsumerRecord(MessageAndOffset)</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka08ConsumerClient.Kafka08ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka08ConsumerClient.Kafka08ConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">Kafka08DataWriter</span></a>&lt;<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="type parameter in Kafka08DataWriter">D</a>&gt; - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Implementation of a Kafka writer that wraps a 0.8 <code>KafkaProducer</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#Kafka08DataWriter-java.util.Properties-">Kafka08DataWriter(Properties)</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#Kafka08DataWriter-org.apache.kafka.clients.producer.Producer-com.typesafe.config.Config-">Kafka08DataWriter(Producer, Config)</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html#KAFKA_DESERIALIZER_TYPE">KAFKA_DESERIALIZER_TYPE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroEventReporter</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block"><a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics-base/gobblin/metrics/reporter/EventReporter.html?is-external=true" title="class or interface in gobblin.metrics.reporter"><code>EventReporter</code></a> that emits events to Kafka as serialized Avro records.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html#KafkaAvroEventReporter-gobblin.metrics.kafka.KafkaAvroEventReporter.Builder-">KafkaAvroEventReporter(KafkaAvroEventReporter.Builder&lt;?&gt;)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroEventReporter.Builder</span></a>&lt;<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="type parameter in KafkaAvroEventReporter.Builder">T</a> extends <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter.Builder</a>&lt;<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="type parameter in KafkaAvroEventReporter.Builder">T</a>&gt;&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Builder for <a href="gobblin/metrics/kafka/KafkaAvroEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroEventReporter</code></a>.</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Factory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroEventReporter.Factory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroReporter.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroReporter</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Kafka reporter for codahale metrics writing metrics in Avro format.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.html#KafkaAvroReporter-gobblin.metrics.kafka.KafkaAvroReporter.Builder-com.typesafe.config.Config-">KafkaAvroReporter(KafkaAvroReporter.Builder&lt;?&gt;, Config)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroReporter.Builder</span></a>&lt;<a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="type parameter in KafkaAvroReporter.Builder">T</a> extends <a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.Builder</a>&lt;<a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="type parameter in KafkaAvroReporter.Builder">T</a>&gt;&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Builder for <a href="gobblin/metrics/kafka/KafkaAvroReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroReporter</code></a>.</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroReporter.BuilderFactory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">A static factory class for obtaining new <a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroReporter.Builder</code></a>s</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroReporter.BuilderImpl</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool"><span class="typeNameLink">KafkaCheckpoint</span></a> - Class in <a href="gobblin/kafka/tool/package-summary.html">gobblin.kafka.tool</a></dt>
<dd>
<div class="block">A class to store kafka checkpoints.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#KafkaCheckpoint-java.util.HashMap-">KafkaCheckpoint(HashMap&lt;Integer, Long&gt;)</a></span> - Constructor for class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">KafkaDataWriterBuilder</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Builder that hands back a <a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer"><code>Kafka08DataWriter</code></a></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html#KafkaDataWriterBuilder--">KafkaDataWriterBuilder()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">KafkaDataWriterBuilder</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaDeserializerExtractor</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">
Extension of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-kafka-common/gobblin/source/extractor/extract/kafka/KafkaExtractor.html?is-external=true" title="class or interface in gobblin.source.extractor.extract.kafka"><code>KafkaExtractor</code></a> that wraps Kafka's <code>Deserializer</code> API.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html#KafkaDeserializerExtractor-gobblin.configuration.WorkUnitState-">KafkaDeserializerExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.Deserializers.html" title="enum in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaDeserializerExtractor.Deserializers</span></a> - Enum in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Pre-defined <code>Deserializer</code> that can be referenced by the enum name.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaDeserializerSource</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Extension of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-kafka-common/gobblin/source/extractor/extract/kafka/KafkaSource.html?is-external=true" title="class or interface in gobblin.source.extractor.extract.kafka"><code>KafkaSource</code></a> that returns a <a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaDeserializerExtractor</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.html#KafkaDeserializerSource--">KafkaDeserializerSource()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaDeserializerSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaEventReporter</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Reports <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/GobblinTrackingEvent.html?is-external=true" title="class or interface in gobblin.metrics"><code>GobblinTrackingEvent</code></a> to a Kafka topic serialized as JSON.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.html#KafkaEventReporter-gobblin.metrics.kafka.KafkaEventReporter.Builder-">KafkaEventReporter(KafkaEventReporter.Builder&lt;?&gt;)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka">KafkaEventReporter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaEventReporter.Builder</span></a>&lt;<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="type parameter in KafkaEventReporter.Builder">T</a> extends <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics-base/gobblin/metrics/reporter/EventReporter.Builder.html?is-external=true" title="class or interface in gobblin.metrics.reporter">EventReporter.Builder</a>&lt;<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="type parameter in KafkaEventReporter.Builder">T</a>&gt;&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Builder for <a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaEventReporter</code></a>.</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaEventReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaEventReporter.BuilderImpl</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaEventReporter.Factory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaEventReporter.Factory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaGsonDeserializer</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Implementation of <code>Deserializer</code> that deserializes Kafka data into a <code>JsonElement</code> using the
<a href="https://docs.oracle.com/javase/7/docs/api/java/nio/charset/StandardCharsets.html?is-external=true#UTF_8" title="class or interface in java.nio.charset"><code>StandardCharsets.UTF_8</code></a> encoding.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html#KafkaGsonDeserializer--">KafkaGsonDeserializer()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaGsonDeserializer.html" title="class in gobblin.source.extractor.extract.kafka">KafkaGsonDeserializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#kafkaPusher">kafkaPusher</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaPusher</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Establishes a connection to a Kafka cluster and pushed byte messages to a specified topic.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaPusher.html#KafkaPusher-java.lang.String-java.lang.String-">KafkaPusher(String, String)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka">KafkaPusher</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#kafkaPusher">kafkaPusher</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#kafkaPusher">kafkaPusher</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaReporter</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Kafka reporter for metrics.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#KafkaReporter-gobblin.metrics.kafka.KafkaReporter.Builder-com.typesafe.config.Config-">KafkaReporter(KafkaReporter.Builder&lt;?&gt;, Config)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaReporter.Builder</span></a>&lt;<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="type parameter in KafkaReporter.Builder">T</a> extends <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics-base/gobblin/metrics/reporter/MetricReportReporter.Builder.html?is-external=true" title="class or interface in gobblin.metrics.reporter">MetricReportReporter.Builder</a>&lt;<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="type parameter in KafkaReporter.Builder">T</a>&gt;&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Builder for <a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka"><code>KafkaReporter</code></a>.</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaReporter.BuilderFactory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">A static factory class for obtaining new <a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaReporter.Builder</code></a>s</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaReporter.BuilderImpl</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaReporterFactory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaReporterFactory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporterFactory.html#KafkaReporterFactory--">KafkaReporterFactory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporterFactory.html" title="class in gobblin.metrics.kafka">KafkaReporterFactory</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/KafkaReportingFormats.html" title="enum in gobblin.metrics"><span class="typeNameLink">KafkaReportingFormats</span></a> - Enum in <a href="gobblin/metrics/package-summary.html">gobblin.metrics</a></dt>
<dd>
<div class="block">Kafka reporting formats enumeration.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaWrapper.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaWrapper</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="block"><span class="deprecationComment">- Use <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-kafka-common/gobblin/kafka/client/GobblinKafkaConsumerClient.html?is-external=true" title="class or interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a></span></div>
</div>
</dd>
</dl>
<a name="I:L">
<!-- -->
</a>
<h2 class="title">L</h2>
<dl>
<dt><a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroDeserializer</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt>
<dd>
<div class="block">The LinkedIn Avro Deserializer (works with records serialized by the <a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize"><code>LiAvroSerializer</code></a>)</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializer.html#LiAvroDeserializer-gobblin.kafka.schemareg.KafkaSchemaRegistry-">LiAvroDeserializer(KafkaSchemaRegistry&lt;MD5Digest, Schema&gt;)</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize">LiAvroDeserializer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroSerializer</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt>
<dd>
<div class="block">LinkedIn's implementation of Avro-schema based serialization for Kafka
TODO: Implement this for IndexedRecord not just GenericRecord</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializer.html#LiAvroSerializer--">LiAvroSerializer()</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize">LiAvroSerializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#listSpecs--">listSpecs()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:M">
<!-- -->
</a>
<h2 class="title">M</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/SimpleKafkaConsumer.html#main-java.lang.String:A-">main(String[])</a></span> - Static method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/SimpleKafkaConsumer.html" title="class in gobblin.kafka.tool">SimpleKafkaConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/KafkaReportingFormats.html#metricReporterBuilder-java.util.Properties-">metricReporterBuilder(Properties)</a></span> - Method in enum gobblin.metrics.<a href="gobblin/metrics/KafkaReportingFormats.html" title="enum in gobblin.metrics">KafkaReportingFormats</a></dt>
<dd>
<div class="block">Get a <a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka"><code>KafkaReporter.Builder</code></a> for this reporting format.</div>
</dd>
</dl>
<a name="I:N">
<!-- -->
</a>
<h2 class="title">N</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderFactory.html#newBuilder--">newBuilder()</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.BuilderFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.BuilderFactory.html#newBuilder--">newBuilder()</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.BuilderFactory.html" title="class in gobblin.metrics.kafka">KafkaReporter.BuilderFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporterFactory.html#newScheduledReporter-com.codahale.metrics.MetricRegistry-java.util.Properties-">newScheduledReporter(MetricRegistry, Properties)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporterFactory.html" title="class in gobblin.metrics.kafka">KafkaReporterFactory</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:O">
<!-- -->
</a>
<h2 class="title">O</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html#onAddJob-gobblin.runtime.api.JobSpec-">onAddJob(JobSpec)</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html#onDeleteJob-java.net.URI-java.lang.String-">onDeleteJob(URI, String)</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html#onUpdateJob-gobblin.runtime.api.JobSpec-">onUpdateJob(JobSpec)</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:P">
<!-- -->
</a>
<h2 class="title">P</h2>
<dl>
<dt><a href="gobblin/metrics/kafka/ProducerCloseable.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">ProducerCloseable</span></a>&lt;<a href="gobblin/metrics/kafka/ProducerCloseable.html" title="type parameter in ProducerCloseable">K</a>,<a href="gobblin/metrics/kafka/ProducerCloseable.html" title="type parameter in ProducerCloseable">V</a>&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Closeable extension of producer</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/ProducerCloseable.html#ProducerCloseable-kafka.producer.ProducerConfig-">ProducerCloseable(ProducerConfig)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/ProducerCloseable.html" title="class in gobblin.metrics.kafka">ProducerCloseable</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaPusher.html#pushMessages-java.util.List-">pushMessages(List&lt;byte[]&gt;)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka">KafkaPusher</a></dt>
<dd>
<div class="block">Push all mbyte array messages to the Kafka topic.</div>
</dd>
</dl>
<a name="I:R">
<!-- -->
</a>
<h2 class="title">R</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.html#reportEventQueue-java.util.Queue-">reportEventQueue(Queue&lt;GobblinTrackingEvent&gt;)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka">KafkaEventReporter</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:S">
<!-- -->
</a>
<h2 class="title">S</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#SCHEMA_VERSION_WRITER_TYPE">SCHEMA_VERSION_WRITER_TYPE</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderImpl.html#self--">self()</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.BuilderImpl</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.BuilderImpl.html#self--">self()</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.BuilderImpl</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.BuilderImpl.html#self--">self()</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.BuilderImpl.html" title="class in gobblin.metrics.kafka">KafkaReporter.BuilderImpl</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializer.html#serialize-java.lang.String-org.apache.avro.generic.GenericRecord-">serialize(String, GenericRecord)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize">LiAvroSerializer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#serialize-gobblin.kafka.tool.KafkaCheckpoint-java.io.OutputStream-">serialize(KafkaCheckpoint, OutputStream)</a></span> - Static method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#serialize-gobblin.kafka.tool.KafkaCheckpoint-java.io.File-">serialize(KafkaCheckpoint, File)</a></span> - Static method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.html#serializer">serializer</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.html" title="class in gobblin.metrics.kafka">KafkaEventReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.html#serializer">serializer</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.html" title="class in gobblin.metrics.kafka">KafkaReporter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/SimpleKafkaConsumer.html#shutdown--">shutdown()</a></span> - Method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/SimpleKafkaConsumer.html" title="class in gobblin.kafka.tool">SimpleKafkaConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#shutDown--">shutDown()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#shutDown--">shutDown()</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/tool/SimpleKafkaConsumer.html" title="class in gobblin.kafka.tool"><span class="typeNameLink">SimpleKafkaConsumer</span></a> - Class in <a href="gobblin/kafka/tool/package-summary.html">gobblin.kafka.tool</a></dt>
<dd>
<div class="block">A simple kafka consumer for debugging purposes.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/SimpleKafkaConsumer.html#SimpleKafkaConsumer-java.util.Properties-gobblin.kafka.tool.KafkaCheckpoint-">SimpleKafkaConsumer(Properties, KafkaCheckpoint)</a></span> - Constructor for class gobblin.kafka.tool.<a href="gobblin/kafka/tool/SimpleKafkaConsumer.html" title="class in gobblin.kafka.tool">SimpleKafkaConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service"><span class="typeNameLink">SimpleKafkaSpecExecutorInstance</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#SimpleKafkaSpecExecutorInstance-com.typesafe.config.Config-com.google.common.base.Optional-">SimpleKafkaSpecExecutorInstance(Config, Optional&lt;Logger&gt;)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service"><span class="typeNameLink">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service"><span class="typeNameLink">SimpleKafkaSpecExecutorInstanceConsumer</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#SimpleKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-com.google.common.base.Optional-">SimpleKafkaSpecExecutorInstanceConsumer(Config, Optional&lt;Logger&gt;)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#SimpleKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-org.slf4j.Logger-">SimpleKafkaSpecExecutorInstanceConsumer(Config, Logger)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#SimpleKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-">SimpleKafkaSpecExecutorInstanceConsumer(Config)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>
<div class="block">Constructor with no logging</div>
</dd>
<dt><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service"><span class="typeNameLink">SimpleKafkaSpecExecutorInstanceProducer</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#SimpleKafkaSpecExecutorInstanceProducer-com.typesafe.config.Config-com.google.common.base.Optional-">SimpleKafkaSpecExecutorInstanceProducer(Config, Optional&lt;Logger&gt;)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#SimpleKafkaSpecExecutorInstanceProducer-com.typesafe.config.Config-org.slf4j.Logger-">SimpleKafkaSpecExecutorInstanceProducer(Config, Logger)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#SimpleKafkaSpecExecutorInstanceProducer-com.typesafe.config.Config-">SimpleKafkaSpecExecutorInstanceProducer(Config)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>
<div class="block">Constructor with no logging</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#SPEC_KAFKA_TOPICS_KEY">SPEC_KAFKA_TOPICS_KEY</a></span> - Static variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#SPEC_STREAMING_BLOCKING_QUEUE_SIZE">SPEC_STREAMING_BLOCKING_QUEUE_SIZE</a></span> - Static variable in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html#SpecExecutorInstanceDataPacket-gobblin.runtime.api.SpecExecutorInstance.Verb-java.net.URI-gobblin.runtime.api.Spec-">SpecExecutorInstanceDataPacket(SpecExecutorInstance.Verb, URI, Spec)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#SPLIT_BY_COLON">SPLIT_BY_COLON</a></span> - Static variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#SPLIT_BY_COMMA">SPLIT_BY_COMMA</a></span> - Static variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#startUp--">startUp()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#startUp--">startUp()</a></span> - Method in class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service"><span class="typeNameLink">StreamingKafkaSpecExecutorInstanceConsumer</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>
<div class="block">SpecExecutorInstanceConsumer that consumes from kafka in a streaming manner</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#StreamingKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-gobblin.runtime.api.MutableJobCatalog-com.google.common.base.Optional-">StreamingKafkaSpecExecutorInstanceConsumer(Config, MutableJobCatalog, Optional&lt;Logger&gt;)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#StreamingKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-gobblin.runtime.api.MutableJobCatalog-org.slf4j.Logger-">StreamingKafkaSpecExecutorInstanceConsumer(Config, MutableJobCatalog, Logger)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html#StreamingKafkaSpecExecutorInstanceConsumer-com.typesafe.config.Config-gobblin.runtime.api.MutableJobCatalog-">StreamingKafkaSpecExecutorInstanceConsumer(Config, MutableJobCatalog)</a></span> - Constructor for class gobblin.service.<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">StreamingKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>
<div class="block">Constructor with no logging</div>
</dd>
<dt><a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener.html" title="class in gobblin.service"><span class="typeNameLink">StreamingKafkaSpecExecutorInstanceConsumer.JobSpecListener</span></a> - Class in <a href="gobblin/service/package-summary.html">gobblin.service</a></dt>
<dd>
<div class="block">JobCatalog listener that puts messages into a blocking queue for consumption by changedSpecs method of
<a href="gobblin/service/StreamingKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service"><code>StreamingKafkaSpecExecutorInstanceConsumer</code></a></div>
</dd>
</dl>
<a name="I:T">
<!-- -->
</a>
<h2 class="title">T</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#topic">topic</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#topic">topic</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html#toString--">toString()</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:U">
<!-- -->
</a>
<h2 class="title">U</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/tool/KafkaCheckpoint.html#update-int-long-">update(int, long)</a></span> - Method in class gobblin.kafka.tool.<a href="gobblin/kafka/tool/KafkaCheckpoint.html" title="class in gobblin.kafka.tool">KafkaCheckpoint</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#updateSpec-gobblin.runtime.api.Spec-">updateSpec(Spec)</a></span> - Method in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:V">
<!-- -->
</a>
<h2 class="title">V</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/KafkaReportingFormats.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.metrics.<a href="gobblin/metrics/KafkaReportingFormats.html" title="enum in gobblin.metrics">KafkaReportingFormats</a></dt>
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.Deserializers.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.Deserializers.html" title="enum in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor.Deserializers</a></dt>
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/KafkaReportingFormats.html#values--">values()</a></span> - Static method in enum gobblin.metrics.<a href="gobblin/metrics/KafkaReportingFormats.html" title="enum in gobblin.metrics">KafkaReportingFormats</a></dt>
<dd>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.Deserializers.html#values--">values()</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.Deserializers.html" title="enum in gobblin.source.extractor.extract.kafka">KafkaDeserializerExtractor.Deserializers</a></dt>
<dd>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#VERB_KEY">VERB_KEY</a></span> - Static variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:W">
<!-- -->
</a>
<h2 class="title">W</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html#withKafkaPusher-gobblin.metrics.kafka.KafkaPusher-">withKafkaPusher(KafkaPusher)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaEventReporter.Builder</a></dt>
<dd>
<div class="block">Set <a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka"><code>KafkaPusher</code></a> to use.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaReporter.Builder.html#withKafkaPusher-gobblin.metrics.kafka.KafkaPusher-">withKafkaPusher(KafkaPusher)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaReporter.Builder</a></dt>
<dd>
<div class="block">Set <a href="gobblin/metrics/kafka/KafkaPusher.html" title="class in gobblin.metrics.kafka"><code>KafkaPusher</code></a> to use.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html#withSchemaRegistry-gobblin.metrics.kafka.KafkaAvroSchemaRegistry-">withSchemaRegistry(KafkaAvroSchemaRegistry)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroEventReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroEventReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html#withSchemaRegistry-gobblin.metrics.kafka.KafkaAvroSchemaRegistry-">withSchemaRegistry(KafkaAvroSchemaRegistry)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroReporter.Builder.html" title="class in gobblin.metrics.kafka">KafkaAvroReporter.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka08DataWriter.html#write-D-gobblin.writer.WriteCallback-">write(D, WriteCallback)</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka08DataWriter.html" title="class in gobblin.kafka.writer">Kafka08DataWriter</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:Z:Z_">
<!-- -->
</a>
<h2 class="title">_</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#Z:Z_capabilities">_capabilities</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#Z:Z_config">_config</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#Z:Z_highWatermark">_highWatermark</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#Z:Z_kafka08Consumer">_kafka08Consumer</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html#Z:Z_kafka08Producer">_kafka08Producer</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceProducer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceProducer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#Z:Z_log">_log</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#Z:Z_lowWatermark">_lowWatermark</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#Z:Z_nextWatermark">_nextWatermark</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html#Z:Z_partitions">_partitions</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstanceConsumer.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstanceConsumer</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html#Z:Z_spec">_spec</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html#Z:Z_specExecutorInstanceUri">_specExecutorInstanceUri</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html#Z:Z_uri">_uri</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html#Z:Z_verb">_verb</a></span> - Variable in class gobblin.service.<a href="gobblin/service/SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket.html" title="class in gobblin.service">SimpleKafkaSpecExecutorInstance.SpecExecutorInstanceDataPacket</a></dt>
<dd>&nbsp;</dd>
</dl>
<a href="#I:A">A</a>&nbsp;<a href="#I:B">B</a>&nbsp;<a href="#I:C">C</a>&nbsp;<a href="#I:D">D</a>&nbsp;<a href="#I:E">E</a>&nbsp;<a href="#I:F">F</a>&nbsp;<a href="#I:G">G</a>&nbsp;<a href="#I:I">I</a>&nbsp;<a href="#I:J">J</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:M">M</a>&nbsp;<a href="#I:N">N</a>&nbsp;<a href="#I:O">O</a>&nbsp;<a href="#I:P">P</a>&nbsp;<a href="#I:R">R</a>&nbsp;<a href="#I:S">S</a>&nbsp;<a href="#I:T">T</a>&nbsp;<a href="#I:U">U</a>&nbsp;<a href="#I:V">V</a>&nbsp;<a href="#I:W">W</a>&nbsp;<a href="#I:Z:Z_">_</a>&nbsp;</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>Package</li>
<li>Class</li>
<li><a href="overview-tree.html">Tree</a></li>
<li><a href="deprecated-list.html">Deprecated</a></li>
<li class="navBarCell1Rev">Index</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?index-all.html" target="_top">Frames</a></li>
<li><a href="index-all.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_bottom");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<a name="skip.navbar.bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
</body>
</html>