title: How to ignore error result in Kafka Connect Elasticsearch
body: <p>I am trying to run kafka connect for elastic search .
  But because of some mistake i entered wrong record in kafka topic .</p>
  
  <p>Now i fixed that issue and inserting correct value but elastic search is still throwing error on previous record in the topic </p>
  
  <p>Here is the error </p>
  
  <pre><code>Caused by: org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error
  
  Caused by: org.apache.kafka.common.errors.SerializationException: com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'lambdaDemo0': was expecting ('true', 'false' or 'null')
   at [Source: (byte[])"lambdaDemo0-9749-0e710000fd04"; line: 1, column: 13]
  </code></pre>
  
  <p>Is there any way i can ignore the older record in the topic and tell kafka connect to pick latest record  ?
  I am trying to delete the topic i get topic marked for deletion but still records are present in the topic .</p>
  
  <p>I tried below two properties but does seems to be working </p>
  
  <pre><code>drop.invalid.message=true
  behavior.on.malformed.documents=ignore
  </code></pre>
  
  <p>Please suggest how i can clean up the wrong record in the topic </p>