Uploaded image for project: 'Atlas'
  1. Atlas
  2. ATLAS-1908

Updating old Kafka consumer api properties to reflect change in new KafkaConsumer configs for Atlas.

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.8.1, 1.0.0
    • None
    • None

    Description

      In ATLAS-1766, the old Kafka consumer api was updated with new Kafka consumer api.
      Due to this update, there were changes in configs.

      New property:
      atlas.kafka.session.timeout.ms=30000

      Renamed property:
      atlas.kafka.auto.commit.enable=false to atlas.kafka.enable.auto.commit=false

      New default value:
      atlas.kafka.auto.offset.reset=smallest to atlas.kafka.auto.offset.reset=earliest

      Need to handle old configs, so that Kafka consumer starts gracefully even if new configs are not added explicitly.

      Attachments

        1. ATLAS-1908.2.patch
          3 kB
          Nixon Rodrigues
        2. ATLAS-1908-1.patch
          16 kB
          Nixon Rodrigues
        3. ATLAS-1908.patch
          16 kB
          Nixon Rodrigues

        Issue Links

          Activity

            People

              nixon Nixon Rodrigues
              nixon Nixon Rodrigues
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: