Update EtlKey.java

Looks like server key value is missing an =
Merge pull request #16 from EricSites/patch-1

Update EtlKey.java
a) Adding Log4j integration b) Batching the earliest and latest offset requests together c) Bug fixed in case the stored offset > latest offset
Fixing IndexOutOfBoundsException when instantiating new String with byte[] payload.

Calling new String(payload, 4, payload.length) causes Java to attempt to read
4 bytes beyond the end of payload, which throws and IndexOutOfBoundsException.
Merge pull request #22 from ottomata/camus-kafka-0.8

LatestSchemaKafkaAvroMessageDecoder : Fixing IndexOutOfBoundsException
Fixing the issue with Default Partitioner

The code in the 08 branch was forcing the use of the Default partitioner. Syncing this with the 07 branch.
Making DefaultPartioner lookup etl.default.timezone
Adding StringRecordWriterProvider.

The returned RecordWriter will write out the CamusRecord's data as String bytes.
This is useful for writing to HDFS directly what comes out of Kafka, instead of
always having to use Avro.
Adding configuration for etl.output.record.delimiter in StringRecordWriterProvider.
Merge pull request #28 from wikimedia/camus-kafka-0.8-pull-requests

Adding StringRecordWriterProvider.
Merge pull request #27 from ottomata/linkedin

Making DefaultPartioner lookup etl.default.timezone
Allow passing a list of brokers to Camus. This removes the need to place the Kafka brokers behind a loadbalancer. That said, the list is only used for the initial metadata discovery and for sending messages back to Kafka - individual broker failures after starting the job can still fail the job.
Merge pull request #30 from smeder/camus-kafka-0.8

Allow passing a list of brokers to Camus.
Adding image
Added code for A) Ignoring server and service for topics B) getConf() NullPointerException issue fixed C) Job Name configuration parameter added D) Hand;ing the case where the current offset is more than the latest available offset
Fixing build erros when imported into eclipse
Adding JsonStringMessageDecoder.java to look for timestamp fields in JSON string payloads.

To use, set:

  camus.message.decoder.class=com.linkedin.camus.etl.kafka.coders.JsonStringMessageDecoder
  camus.message.timestamp.format=<your-timestamp-format:HH:mm:ss>
  camus.message.timestamp.field=<your-timestamp-field>

This adds com.google.code.gson as a dependency.
Merge pull request #31 from wikimedia/camus-kafka-0.8-pull-requests

Adding JsonStringMessageDecoder.java to look for timestamp fields in JSON string payloads.
Fix the -p problem when loading camus.prop from classpath
Merge pull request #32 from bbaugher/camusPropertiesClasspathFix

Fix the -p problem when loading camus.prop from classpath