如何取回Kafka生产者和消费者配置(Java API)?
How to get back Kafka producer and consumer configuration (Java API)?
用例如下。
我正在 Java 代码中传递生产者或消费者对许多对象实例的引用。
在其中一些,我想对 Kafka 配置进行一些检查。
这意味着我想回来,Kafka Producer/Consumer(包括默认值)中存储了哪些有效配置。
我在 java 文档中没有看到明确的内容:
那么,如何取回Kafka生产者和消费者配置?
很遗憾,这是不可能的。我不得不承认它可能是一个有用的功能,至少可以显示 "core" 配置属性(例如,避免获得 "secrets" 用于身份验证的可能性)。
我今天看到的唯一解决方案是在 consumer/producer 实例和用于设置客户端配置的相关属性包之间有一个 link。我知道这是浪费内存,因为这样的配置在客户端内部,但你需要保留你的属性包才能拥有它。
用例如下。 我正在 Java 代码中传递生产者或消费者对许多对象实例的引用。 在其中一些,我想对 Kafka 配置进行一些检查。 这意味着我想回来,Kafka Producer/Consumer(包括默认值)中存储了哪些有效配置。 我在 java 文档中没有看到明确的内容:
那么,如何取回Kafka生产者和消费者配置?
很遗憾,这是不可能的。我不得不承认它可能是一个有用的功能,至少可以显示 "core" 配置属性(例如,避免获得 "secrets" 用于身份验证的可能性)。 我今天看到的唯一解决方案是在 consumer/producer 实例和用于设置客户端配置的相关属性包之间有一个 link。我知道这是浪费内存,因为这样的配置在客户端内部,但你需要保留你的属性包才能拥有它。