我有以下设置，如文档中所述。我使用的是KafkaFlow版本2.4.0。请在下面找到相同的源代码。但是我没有收到任何消息。

`services.AddKafka(kafka => kafka
    .AddCluster(cluster => cluster
        .WithBrokers(new[] { "localhost:9092" })
        .AddProducer<KafkaCommentProducer>(
            producer => 
                producer.DefaultTopic("Test")
            )
    )
);`

`public class KafkaCommentProducer: IKafkaCommentProducer
{
    private readonly IMessageProducer<KafkaCommentProducer> _producer;

    public ProductEventsProducer(IMessageProducer<KafkaCommentProducer> producer)
    {
        _producer = producer;
    }

    public Task ProduceAsync(Product product) =>
        _producer
            .ProduceAsync(product.Id.ToString(), product);
}
`

`TestController(IKafkaCommentProducer producer)
var result = await producer.ProduceAsync(message);`

字符串

消费者

第一个月
我尝试了一个基于类型的生产者和.net6web应用程序