Hi; we're using https://github.com/logstash-plugins/logstash-integration-kafka to transcribe Kafka Avro message fields from Kafka to an Elastic search index for our reports.
Recently we noticed that the consumer by default uses read_uncommitted, which when combined with a transactional producer lead to fields being transcribed for messages that were later rolled back, messing up our reports.
There seem to be quite a few overrideable properties already, yet I could not find anything corresponding to: https://kafka.apache.org/25/documentation/#isolation.level
Is there any way to set the consumer isolation level for Kafka to read_committed? Could it be added or documented?