Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.14.2
-
None
-
Unknown
Description
When we initialize a KafkaConsumer, we can set the property called isolation.level to control what transaction records are exposed to the consumer. Two values are then possible, read_uncommitted to retrieve all records, independently on the transaction outcome (if any), and read_committed to get only the records from committed transactions.
in,
org.apache.kafka.clients.consumer.ConsumerConfig
DEFAULT_ISOLATION_LEVEL is IsolationLevel.READ_UNCOMMITTED.toString().toLowerCase(Locale.ROOT);
and there is no way we can change ISOLATION_LEVEL to IsolationLevel.READ_COMMITTED by camel-kafka
************************************************************************************************************************************************************
org.apache.kafka.clients.consumer.ConsumerConfig
----------------------------------------------------------------