If you use Rest Proxy API to send data to Kafka
{
"records":[{
"key": {
"territoryCode": "{{ doc.name }}"
},
"value": {{ json.dumps(doc) }}
}]
}
https://github.com/frappe/frappe/issues/3928#issuecomment-330187516