Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-9739

Specifying kafka partition without hashing in PublishKafka processors

    XMLWordPrintableJSON

Details

    • Wish
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • None

    Description

      Hello,

      I already asked a question in Cloudera:

      https://community.cloudera.com/t5/Support-Questions/NiFi-Publish-Kafka-hashes-partition-info-automatically/m-p/336941

      In short, I need to choose the kafka partition of my flowfiles without hashing. Even if I use Expression Language Partitioner as a partitioner class, it does not publish my flowfiles to appropriate partitions. Can we add another parameter that specifies whether partition values should be hashed or not in publish kafka processor/s.

      Attachments

        Activity

          People

            Unassigned Unassigned
            yemregurses Yunus Emre Gürses
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: