0

在我的 Confluent Kafka .NET 应用程序中,我有一个生产者,它使用拦截器在发送消息之前对其进行加密。我想知道是否可以将标头数据添加到可以在消费者解密消息之前读取的加密消息。加密由AwsCrypto.

为了检查这一点,我让我的消费者在 Consume() 之后输出以下日志条目:

_log.LogInformation("Message headers: " + consumeResult.Message.Headers.ToString());

这是我在日志中看到的:

消息头:Confluent.Kafka.Headers

如何查看实际的标头数据?

4

0 回答 0