[ 
https://issues.apache.org/jira/browse/NIFI-14470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945494#comment-17945494
 ] 

Paul Grey commented on NIFI-14470:
----------------------------------

[https://github.com/greyp9/nifi-tidbits/tree/main/jira/14470/]

I just tested this scenario using the nifi 2.3 docker image.  This is a link to 
the flow definition I used.  I'm omitting the EvaluateJsonPath variable, as it 
should not affect the test.  Things look ok to me.

Do you see the same when you try out this sample?  Any noteworthy differences 
in your processor configuration?

 

> PublishKafka not able to add kafka key from attribute
> -----------------------------------------------------
>
>                 Key: NIFI-14470
>                 URL: https://issues.apache.org/jira/browse/NIFI-14470
>             Project: Apache NiFi
>          Issue Type: Bug
>    Affects Versions: 2.0.0-M4
>            Reporter: Rabii
>            Priority: Major
>
> Using 2.0.0-M4 to migrate from PublishKafka2_6/ConsumeKafka2_6 to the new 
> PublishKafka/ConsumeKafka Processors since M4 supports both type of 
> processors.
>  
> Generate flowFile as json, attach an attribute to the messages, publish 
> message using PublishKafka and kafka key from the created attribute.
> Result message without key. It should be easy to reproduce.
> The same logic works with PublishKafka2_6



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to