title: Kafka client upgrade from 0.8.2.1 to 2.1.1
body: <p>I am planning to upgrade the kafka client from 0.8.2.1 to 2.1.1. </p>
  
  <p>Need help with how to go about it?</p>
  
  <p>My existing code is as shown here <a href="https://stackoverflow.com/a/37384777">https://stackoverflow.com/a/37384777</a>.
  "kafka.consumer.KafkaStream" is depricated in 2.1.1</p>
  
  <p>Need direction on how to go about this - </p>
  
  <p>I Updated my pom to </p>
  
  <pre><code>&lt;dependency&gt;
      &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
      &lt;artifactId&gt;kafka-clients&lt;/artifactId&gt;
      &lt;version&gt;2.1.1&lt;/version&gt;
      &lt;scope&gt;provided&lt;/scope&gt;
  &lt;/dependency&gt;
  </code></pre>