https://community.cloudera.com/t5/Support-Questions/Kafka-Key-not-populated-PublishKafkaRecord/m-p/336655#M232336 <P><a href="https://community.cloudera.com/t5/user/viewprofilepage/user-id/95964">@CloudNaive</a>&nbsp;,</P><P>&nbsp;</P><P>It seems that the "Message Key Field" property doesn't work with a nested structure. This property must refer to a top level field of the record that contains the key value.</P><P>In the example below I used UpdateRecord to create a top level field called "id" and update it with the value of "metadata.aggregateId". Them, on the PublishKafkaRecord I was able to use the "id" field as the Kafka message key.</P><P><span class="lia-inline-image-display-wrapper lia-image-align-inline" image-alt="araujo_0-1645348571104.png" style="width: 704px;"><img src="https://community.cloudera.com/t5/image/serverpage/image-id/33623i783B81EC96AC96F1/image-dimensions/704x401?v=v2" width="704" height="401" role="button" title="araujo_0-1645348571104.png" alt="araujo_0-1645348571104.png" /></span></P><P>&nbsp;</P><P>Cheers,</P><P>André</P><P>&nbsp;</P> Sun, 20 Feb 2022 09:16:38 GMT araujo 2022-02-20T09:16:38Z