[GitHub] [nifi] greyp9 commented on pull request #6131: NIFI-9822 - ConsumeKafkaRecord allows writing out Kafka record key

[GitBox]

greyp9 commented on PR #6131:
URL: https://github.com/apache/nifi/pull/6131#issuecomment-1224730836

   > ```
   > {
   >   "key": {
   >     "type": "person"
   >   },
   >   "value": {
   >     "name": "Mark",
   >     "number": 49
   >   },
   >   "headers": {
   >      "headerA": "headerAValue"
   >   }
   > }
   > ```
   
   Thanks.  There are enough permutations related to these changes such that 
I'm not sure what should be emitted for all of them.  I've made some 
simplifying assumptions; those may need adjustments.
   
   Maybe a concrete example would help.  Given the record above, and the 
processor PublishKafkaRecord_2_6:
   
   [Processor Property] PublishStrategy
   ```
   if (Use Wrapper) {
       Kafka Record:
       Key = ?
       Value = ?
       Headers = ?
   } else {
       Kafka Record:
       Key = ?
       Value = ?
       Headers = ?
   }
   ```
   
   ---
   
   [Processor Property] Attributes To Send as Headers (Regex)
   ```
   if (Use Wrapper) {
       send attributes in wrapper record (do not add to kafka headers)
   } else {
       send attributes in kafka headers
   }
   ```
   is this high-level logic valid?
   
   ---
   
   [Processor Property] Message Key Field
   ```
   if (Use Wrapper) {
       ignore (null key)
   } else {
       send key (if record field exists) in Kafka key
   }
   ```
   
   is this right?
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscr...@nifi.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org