用例如下。 我正在通过 Java 代码中的许多对象实例传递生产者或消费者引用。 在其中一些,我想对 Kafka 配置进行一些检查。 这意味着我想回来,Kafka Producer/Consumer 中存储了哪些有效配置(包括默认值)。 我没有在 Java 文档中看到明确的内容:
那么,如何返回Kafka生产者和消费者的配置呢?
最佳答案
很遗憾,这是不可能的。我不得不承认,它可能是一个有用的功能,至少可以显示“核心”配置属性(例如,避免获得身份验证的“ secret ”)。 我今天为您看到的唯一解决方案是在消费者/生产者实例和用于设置客户端配置的相关属性包之间建立链接。我知道这是一种内存浪费,因为这样的配置在客户端内部,但您需要保留您的属性包才能拥有它。
关于java - 如何取回 Kafka 生产者和消费者配置(Java API)?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47671049/