确定librdkafka中的组长

Question

有没有办法确定librdkafka中的组长？

由于没有办法传递自定义分区策略，因此我需要一些技巧来达到此目的。我的特定客户必须是组长，如果不是，我应该退出。

或者，有没有办法确保没有其他消费者使用当前的消费者组id运行？

Answer 1

目前，识别使用者组领导者的唯一方法是启用cgrp调试上下文(将debug配置属性设置为cgrp)，然后捕获日志(使用log_cb或event API)，并匹配以下日志行(在未来版本中可能会更改)：

1591771297.737 RDKAFKA-7-JOINGROUP: rdkafka#consumer-1: [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId rdkafka-b5751775-49f4-4ac8-a912-f5800f5bffbe (me), my MemberId rdkafka-b5751775-49f4-4ac8-a912-f5800f5bffbe, 1 members in group: (no error)

只有当LeaderId与MemberId相同时，才会包含"(me)“部分。