title: updating kafka dependency in camus is causing messages not read by EtlRecordReader
body: <p>In my project camus is used for long time and it is never get updated.
  The camus project uses kafka version 0.8.2.2. I want to find a workaround to use kafka 1.0.0.</p>
  
  <p>So I cloned the directory and updated the dependency. When I do that the Message here requires additional parameters <a href="https://github.com/rajcspsg/camus/blob/updated-dependencies/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/mapred/EtlRecordReader.java#L232-L233" rel="nofollow noreferrer">here</a>.</p>
  
  <p>As given in the github link above, the code compiles but the messages are not read from the kafka due to the condition <a href="https://github.com/rajcspsg/camus/blob/updated-dependencies/camus-etl-kafka/src/main/java/com/linkedin/camus/etl/kafka/mapred/EtlRecordReader.java#L237" rel="nofollow noreferrer">here</a>. </p>
  
  <p>Is it possible to update the kafka dependency along with appropriate data constructors of <code>kafka.message.Message</code> and make it work.  </p>