Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-17913

camel-kafka - Not able to set IsolationLevel using consumer parameters

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 3.14.2
    • 3.17.0
    • camel-kafka
    • 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

      ----------------------------------------------------------------

      Attachments

        1. image-2022-04-06-19-26-31-080.png
          33 kB
          itachi uchiha

        Activity

          People

            davsclaus Claus Ibsen
            itachi777 itachi uchiha
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: