使用Confluent .NET Client列出Kafka消费组时遇参数空值异常

我之前也碰到过类似的情况，结合你的描述，咱们一步步来排查：

可能的原因分析 #

1. 方法重载调用错误
   你提到只传入了TimeSpan参数，但要注意Confluent .NET Client 1.3.0的AdminClient有两个ListGroups重载：

   • 无参数选项的版本：ListGroups(TimeSpan timeout)
   • 带选项的版本：ListGroups(ListGroupsOptions options, TimeSpan timeout)
     如果你不小心误传了null作为ListGroupsOptions参数（比如代码里写了ListGroups(null, TimeSpan.FromSeconds(5))），内部逻辑可能会错误地检查options.Group属性，进而抛出这个异常。

2. 旧版本客户端的已知Bug
   1.3.0是比较早期的版本（2019年发布），这个版本的ListGroups方法确实存在一些内部逻辑问题——即使调用正确的无选项重载，底层可能还是会错误地要求group参数不为null，而这个问题在后续的版本中已经被修复了。

解决办法 #

1. 确认并修正方法调用 #

检查你的代码，确保调用的是无ListGroupsOptions参数的重载：

var result = await adminClient.ListGroups(TimeSpan.FromSeconds(10));

如果之前误传了null作为选项参数，删掉这个参数即可。

2. 升级Confluent .NET Client版本 #

因为1.3.0的这个Bug是已知的，最彻底的解决办法是升级到与你的Kafka 2.4.0兼容的较新版本：

• 推荐升级到1.4.0版本（这个版本专门适配Kafka 2.4.x），或者更高的兼容版本（比如1.7.x，只要不超过Kafka版本的兼容范围）。
• 在NuGet包管理器中搜索Confluent.Kafka，选择对应的版本安装即可。

3. 临时替代方案（如果无法立即升级） #

如果暂时不能升级客户端，可以通过调用系统命令行工具来获取消费组列表，解析输出结果作为临时解决办法：

var process = new Process
{
    StartInfo = new ProcessStartInfo
    {
        FileName = "kafka-consumer-groups.bat",
        Arguments = "--list --bootstrap-server \"localhost:9092\"",
        RedirectStandardOutput = true,
        UseShellExecute = false,
        CreateNoWindow = true
    }
};

process.Start();
var output = process.StandardOutput.ReadToEnd();
process.WaitForExit();

var consumerGroups = output.Split(new[] { Environment.NewLine }, StringSplitOptions.RemoveEmptyEntries);
// 处理consumerGroups列表

内容的提问来源于stack exchange，提问作者MSE