Uploaded image for project: 'CDAP'
  1. CDAP
  2. CDAP-4984

KafkaProducer sink should accept any field for the partition key

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Won't Fix
    • Affects Version/s: 3.3.1
    • Fix Version/s: 4.0.0
    • Component/s: ETL
    • Labels:
      None
    • Rank:
      1|hzz6zb:

      Description

      If it is not an int or long, it can hash the field value. Also, it would be useful to specify an expression in some way, such as valueOf(stringField). Or what is the recommended way to do something like that? Add an extra transform that evaluates that expression? Perhaps with good enough docs, that may work.

        Attachments

          Activity

            People

            • Assignee:
              ashau Albert Shau
              Reporter:
              andreas Andreas Neumann
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: