如何使用www.example.com核心为消费者创建Kafka DLQasp.net

var kafkaConfig = new ConsumerConfig
            { 
                GroupId = _configuration["ConsumerGroup"],
                BootstrapServers = _configuration["KafkaServer"]
            };

            using (var consumer = new ConsumerBuilder<int, string>(kafkaConfig).Build())
            {
                consumer.Subscribe(_configuration["Topic"]);

                try
                {
                    while (!stoppingToken.IsCancellationRequested)
                    {
                        try 
                        {
                            var consumeResult = consumer.Consume(stoppingToken);
                            Console.WriteLine($"Consumed message '{consumeResult.Value}' at: '{consumeResult.TopicPartitionOffset}'.");

                            if (!TryConsume(consumeResult, stoppingToken)) 
                            {
                                await _retryQueueProducer.RetryAsync(consumeResult);
                            }
                        }
                        catch (ConsumeException e)
                        {
                            Console.WriteLine($"Error occured: {e.Error.Reason}");
                        }
                    }
                }
                finally
                {
                    // Ensure the consumer leaves the group cleanly and final offsets are committed.
                    consumer.Close();
                }
            }

上面一个是示例代码
如何在DLQ中显示失败的消息值