title: Back pressure in Kafka
body: <p>I have a situation in Kafka where the producer publishes the messages at a very higher rate than the consumer consumption rate. I have to implement the back pressure implementation in kafka for further consumption and processing.</p>
  
  <p>Please let me know how can I implement in spark and also in normal java api.</p>