情况如下。
我的一些Flume与Kafka相连，对负载非常敏感。它们是dbs，确实喜欢过载。
我想动态设置一些主题的配额值，这取决于这些接收器上的总负载。我使用kafka connect和基于kstreams的自制Streaming应用程序将数据输入dbs。
我知道我不能在主题上设置配额，但是在client.id上。总之，最后我更喜欢控制具体的主题。
尤其是后来我更喜欢有一个工具（也许是自编程的）来关闭从sink load到kafka配额的反馈循环。
更复杂的是，在使用streams时，client.id使用类似postfix的后缀进行扩展

StreamThread-1-consumer-f1835e80-e8ae-428a-a40e-2a44aab0e9ae

我有管理员访问的主题，所以我可以“嗅探”所有的消息。问题是：
如何获取特定主题中消息的client.id，而不询问开发人员，他们实现了什么，或者是否更改了与client.id相关的内容？
提前谢谢！