apache-kafka - Khafka 消费者阅读事件中心的垃圾价值

Question

我正在使用消费者从事件中心读取字节数组内容，我有一个垃圾值，后跟项目计数（字节数组），然后是 fetched 字节数组。例如值 [-95 , 4 , 50,48,50,48] 我希望删除这个垃圾 -95 ，是 kafka 问题还是事件中心问题。如果是这样如何解决它，需要帮助

标签： apache-kafkaazure-eventhub

Answer 1

您的消费者会收到发送到事件中心的任何内容。事件中心永远不会更改 EventData 中的有效负载并按原样中继它。因此，如果您看到某些内容从消费者的角度来看似乎发生了变化，我强烈建议您检查发件人并确保他们发送正确的有效载荷。