【发布时间】:2020-10-09 14:06:49
【问题描述】:
我的应用程序使用的依赖包中有这个ConsumerBuilder:
using var consumer = new ConsumerBuilder<byte[], byte[]>(config).SetErrorHandler(
(consumeException, error) => throw new Exception($"KafkaTask Kafka error, Fatal:{error.IsFatal}, " +
$"Code:{error.Code}, {error.IsBrokerError}, " +
$"IsLocalError:{error.IsLocalError}, Reason:{error.Reason}")).Build();
我想添加一些东西,如果抛出异常,则将变量设置为 true。我该怎么做?
【问题讨论】:
-
通过添加
trycatch块。 -
当然,在抛出异常之前设置变量。您需要将代码括在大括号 (
{ variable = true; throw new ...; }) 中。请注意,抛出Exception被认为是不好的做法;您应该使用更合适的派生类型。