Как публиковать сообщения от потребителей Kafka в представлениях Django

Question

Я новичок в Джанго и Кафке. У меня есть требования, чтобы получить сообщение в формате ниже в Kafka Consumer и опубликовать его в виде в DRF. Ниже приведен формат моего сообщения и подробное представление сообщения, в которое нужно отправить сообщение Kafka.

My django Посмотреть сообщение:

Отправка в формате Msg от производителя Kafka

 from kafka import KafkaProducer
import json
from bson import json_util
post = []
prod = KafkaProducer(bootstrap_servers='localhost:9092')
while(True) :
    title = input("Title :")
    content = input("Content :")
    author = input ("Author :")

    post.append({
        "title" : title, 
        "content" : content,
        "author" : author
        })
    prod.send('hung11898',json.dumps(post, indent=4, default=json_util.default).encode('utf-8'))
    prod.flush()
    cont = input("Add another Post ?(Y/N)")
    if cont == 'N' :
        break