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

camel-kafka set custom timestamp

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.25.3, 3.8.0
    • 3.10.0
    • camel-kafka
    • None
    • Unknown

    Description

      The kafka producer supports the possibility to pass on a (custom) timestamp with the record. The camel-kafka component does not leverage this, currently. A Camel header seems like a good option to provide this. The consumer already creates a kafka.TIMESTAMP header (not yet documented). I suggest to use a different header to avoid misconfiguration in case of "kafka to kafka" scenarios. kafka.OVERRIDE_TIMESTAMP (being a one-time header) looks like a good idea, similar to the existing kafka.OVERRIDE_TOPIC.

      What do you think?

      Attachments

        Issue Links

          Activity

            People

              ramu11 Ramu
              jenskordowski Jens Kordowski
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: