我终于想起要询问Kafka邮件列表，并得到以下答复，效果很好。
是的，您可以将消息作为字节数组发送。如果查看Message类的构造函数，您将看到-
def this（bytes：Array [Byte]）
现在，查看生产者send（）API-
def send（producerData：ProducerData [K，V] *）
您可以将V设置为Message类型，将K设置为所需密钥。如果您不关心使用键进行分区，请将其也设置为“消息类型”。
谢谢，Neha
我终于想起要询问Kafka邮件列表，并得到以下答复，效果很好。
是的，您可以将消息作为字节数组发送。如果查看Message类的构造函数，您将看到-
def this（bytes：Array [Byte]）
现在，查看生产者send（）API-
def send（producerData：ProducerData [K，V] *）
您可以将V设置为Message类型，将K设置为所需密钥。如果您不关心使用键进行分区，请将其也设置为“消息类型”。
谢谢，Neha
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
